From ccd84dadf7e7b1b5c037933f3a2ae56272c62919 Mon Sep 17 00:00:00 2001 From: Bjørn Madsen Date: Mon, 7 Aug 2017 08:57:49 +0200 Subject: Move circe package object --- .../sttp/asynchttpclient/monix/MonixAsyncHttpClientHandler.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) (limited to 'async-http-client-handler/monix/src/main') 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] = -- cgit v1.2.3