diff options
Diffstat (limited to 'async-http-client-backend/monix/src/main/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixBackend.scala')
| -rw-r--r-- | async-http-client-backend/monix/src/main/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixBackend.scala | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/async-http-client-backend/monix/src/main/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixBackend.scala b/async-http-client-backend/monix/src/main/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixBackend.scala index 3d54b26..915b325 100644 --- a/async-http-client-backend/monix/src/main/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixBackend.scala +++ b/async-http-client-backend/monix/src/main/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixBackend.scala @@ -11,6 +11,7 @@ import com.softwaremill.sttp.{ Utf8, concatByteBuffers } +import io.netty.buffer.{ByteBuf, Unpooled} import monix.eval.Task import monix.execution.{Cancelable, Scheduler} import monix.reactive.Observable @@ -23,8 +24,8 @@ class AsyncHttpClientMonixBackend private (asyncHttpClient: AsyncHttpClient, clo implicit scheduler: Scheduler) extends AsyncHttpClientBackend[Task, Observable[ByteBuffer]](asyncHttpClient, TaskMonad, closeClient) { - override protected def streamBodyToPublisher(s: Observable[ByteBuffer]): Publisher[ByteBuffer] = - s.toReactivePublisher + override protected def streamBodyToPublisher(s: Observable[ByteBuffer]): Publisher[ByteBuf] = + s.map(Unpooled.wrappedBuffer).toReactivePublisher override protected def publisherToStreamBody(p: Publisher[ByteBuffer]): Observable[ByteBuffer] = Observable.fromReactivePublisher(p) |