diff options
Diffstat (limited to 'async-http-client-handler/monix/src/main')
| -rw-r--r-- | async-http-client-handler/monix/src/main/scala/com/softwaremill/sttp/asynchttpclient/monix/MonixAsyncHttpClientHandler.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/async-http-client-handler/monix/src/main/scala/com/softwaremill/sttp/asynchttpclient/monix/MonixAsyncHttpClientHandler.scala b/async-http-client-handler/monix/src/main/scala/com/softwaremill/sttp/asynchttpclient/monix/MonixAsyncHttpClientHandler.scala index c782519..5b6426f 100644 --- a/async-http-client-handler/monix/src/main/scala/com/softwaremill/sttp/asynchttpclient/monix/MonixAsyncHttpClientHandler.scala +++ b/async-http-client-handler/monix/src/main/scala/com/softwaremill/sttp/asynchttpclient/monix/MonixAsyncHttpClientHandler.scala @@ -25,9 +25,8 @@ class MonixAsyncHttpClientHandler private ( closeClient) { override protected def streamBodyToPublisher( - s: Observable[ByteBuffer]): Publisher[ByteBuffer] = { + s: Observable[ByteBuffer]): Publisher[ByteBuffer] = s.toReactivePublisher - } override protected def publisherToStreamBody( p: Publisher[ByteBuffer]): Observable[ByteBuffer] = |