Fix request stream close on stream pause (#36)

Resolves #31
connectrpc · Apr 12, 2023 · 5da30f1 · 5da30f1
1 parent 85436d7
commit 5da30f1
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/okhttp/src/main/kotlin/build/buf/connect/okhttp/OkHttpStream.kt b/okhttp/src/main/kotlin/build/buf/connect/okhttp/OkHttpStream.kt
@@ -193,8 +193,9 @@ internal class PipeDuplexRequestBody(
                 bufferedSink.writeAll(buffer)
                 bufferedSink.flush()
             }
-        } finally {
+        } catch (e: Throwable) {
             close()
+            throw e
         }
     }