Stream the response body in Monix IO scheduler. Fix typo in variable name.

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
     })