Update send() to forward all errors (#22)

Author: buildbreaker

library/src/main/kotlin/build/buf/connect/http/HTTPClientInterface.kt

@@ -56,8 +56,12 @@ class Stream(
         if (isClosed()) {
             return Result.failure(IllegalStateException("cannot send. underlying stream is closed"))
         }
-        onSend(buffer)
-        return Result.success(Unit)
+        return try {
+            onSend(buffer)
+            Result.success(Unit)
+        } catch (e: Throwable) {
+            Result.failure(e)
+        }
     }
 
     fun close() {

okhttp/src/main/kotlin/build/buf/connect/okhttp/OkHttpStream.kt

@@ -193,7 +193,7 @@ internal class PipeDuplexRequestBody(
                 bufferedSink.writeAll(buffer)
                 bufferedSink.flush()
             }
-        } catch (e: Throwable) {
+        } finally {
             close()
         }
     }