sending & receiving a stream

3 files changed, 13 insertions, 2 deletions

diff --git a/core/src/main/scala/com/softwaremill/sttp/HttpConnectionSttpHandler.scala b/core/src/main/scala/com/softwaremill/sttp/HttpConnectionSttpHandler.scala
index 8144496..82e7524 100644
--- a/core/src/main/scala/com/softwaremill/sttp/HttpConnectionSttpHandler.scala
+++ b/core/src/main/scala/com/softwaremill/sttp/HttpConnectionSttpHandler.scala
@@ -5,6 +5,8 @@ import java.net.HttpURLConnection
 import java.nio.channels.Channels
 import java.nio.file.Files
 
+import com.softwaremill.sttp.model._
+
 import scala.annotation.tailrec
 import scala.io.Source
 
diff --git a/core/src/main/scala/com/softwaremill/sttp/SttpHandler.scala b/core/src/main/scala/com/softwaremill/sttp/SttpHandler.scala
index f86467b..aaab92d 100644
--- a/core/src/main/scala/com/softwaremill/sttp/SttpHandler.scala
+++ b/core/src/main/scala/com/softwaremill/sttp/SttpHandler.scala
@@ -1,5 +1,7 @@
 package com.softwaremill.sttp
 
+import com.softwaremill.sttp.model.{ResponseAs, ResponseAsStream}
+
 import scala.language.higherKinds
 
 trait SttpHandler[R[_]] {
@@ -7,6 +9,7 @@ trait SttpHandler[R[_]] {
 }
 
 trait SttpStreamHandler[R[_], S] extends SttpHandler[R] {
-  def send[T](request: Request, responseAsStream: ResponseAsStream[S]): R[Response[S]]
-  def sendStream[T](request: Request, contentType: String, stream: S, responseReader: ResponseAs[T]): R[Response[T]]
+  def send(request: Request, responseAsStream: ResponseAsStream[S]): R[Response[S]]
+  def sendStream[T](request: Request, contentType: String, stream: S, responseAs: ResponseAs[T]): R[Response[T]]
+  def sendStream(request: Request, contentType: String, stream: S, responseAsStream: ResponseAsStream[S]): R[Response[S]]
 }
\ No newline at end of file
diff --git a/core/src/main/scala/com/softwaremill/sttp/package.scala b/core/src/main/scala/com/softwaremill/sttp/package.scala
index 07b4df6..b007d6a 100644
--- a/core/src/main/scala/com/softwaremill/sttp/package.scala
+++ b/core/src/main/scala/com/softwaremill/sttp/package.scala
@@ -132,6 +132,12 @@ package object sttp {
 
       handler.sendStream(this, contentType, stream, responseAs)
     }
+
+    def sendStream[R[_], S](contentType: String, stream: S, responseAs: ResponseAsStream[S])(
+      implicit handler: SttpStreamHandler[R, S], isRequest: IsRequest[U]): R[Response[S]] = {
+
+      handler.sendStream(this, contentType, stream, responseAs)
+    }
   }
 
   object RequestTemplate {