Mark duplex streaming bodies as one shot (#155)

Update PipeDuplexRequestBody to indicate that request bodies are one shot (they can't be re-read).
connectrpc · Dec 6, 2023 · de27a21 · de27a21
1 parent dff2aa7
commit de27a21
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/okhttp/src/main/kotlin/com/connectrpc/okhttp/OkHttpStream.kt b/okhttp/src/main/kotlin/com/connectrpc/okhttp/OkHttpStream.kt
@@ -213,6 +213,8 @@ internal class PipeDuplexRequestBody(
 
     override fun isDuplex() = true
 
+    override fun isOneShot() = true
+
     fun close() {
         try {
             bufferedSink.close()