diff options
author | Omar Alejandro Mainegra Sarduy <omainegra@gmail.com> | 2017-08-07 10:58:19 -0400 |
---|---|---|
committer | Omar Alejandro Mainegra Sarduy <omainegra@gmail.com> | 2017-08-07 10:58:19 -0400 |
commit | c4bce97aaf1eb60a5dbb7f58ae33dc57dcdfa9a2 (patch) | |
tree | ffb91757c886a93dd05a2e943301bc6ee112eb96 /okhttp-client-handler | |
parent | affc8cef21ba2ff8f46b2144b2064b8150840f2b (diff) | |
download | sttp-c4bce97aaf1eb60a5dbb7f58ae33dc57dcdfa9a2.tar.gz sttp-c4bce97aaf1eb60a5dbb7f58ae33dc57dcdfa9a2.tar.bz2 sttp-c4bce97aaf1eb60a5dbb7f58ae33dc57dcdfa9a2.zip |
Stream the response body in Monix IO scheduler. Fix typo in variable name.
Diffstat (limited to 'okhttp-client-handler')
-rw-r--r-- | okhttp-client-handler/monix/src/main/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixClientHandler.scala | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/okhttp-client-handler/monix/src/main/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixClientHandler.scala b/okhttp-client-handler/monix/src/main/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixClientHandler.scala index 1eb353c..ecfb30e 100644 --- a/okhttp-client-handler/monix/src/main/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixClientHandler.scala +++ b/okhttp-client-handler/monix/src/main/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixClientHandler.scala @@ -21,15 +21,17 @@ class OkHttpMonixClientHandler private (client: OkHttpClient)( extends OkHttpAsyncClientHandler[Task, Observable[ByteBuffer]](client, TaskMonad) { + private lazy val io = Scheduler.io("sttp-monix-io") + override def streamToRequestBody( stream: Observable[ByteBuffer]): Option[OkHttpRequestBody] = Some(new OkHttpRequestBody() { override def writeTo(sink: BufferedSink): Unit = stream .consumeWith( - Consumer.foreach(chunck => sink.write(chunck.array())) + Consumer.foreach(chunk => sink.write(chunk.array())) ) - .runAsync + .runAsync(io) override def contentType(): MediaType = null }) |