aboutsummaryrefslogtreecommitdiff
path: root/async-http-client-handler/monix/src/main
diff options
context:
space:
mode:
authoradamw <adam@warski.org>2017-07-24 17:05:07 +0200
committeradamw <adam@warski.org>2017-07-24 17:05:07 +0200
commit81d290bc8658841f48d8a7fc10d88813eba16ffc (patch)
tree04ddb3defcfd65b041ec58046958a808a475b512 /async-http-client-handler/monix/src/main
parentb5f0c5387f7a98875f60fdf09c8dbe56e5c2766d (diff)
downloadsttp-81d290bc8658841f48d8a7fc10d88813eba16ffc.tar.gz
sttp-81d290bc8658841f48d8a7fc10d88813eba16ffc.tar.bz2
sttp-81d290bc8658841f48d8a7fc10d88813eba16ffc.zip
Hiding specific implementation types
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.scala7
1 files changed, 4 insertions, 3 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 8e6c70d..2357c06 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
@@ -2,6 +2,7 @@ package com.softwaremill.sttp.asynchttpclient.monix
import java.nio.ByteBuffer
+import com.softwaremill.sttp.SttpHandler
import com.softwaremill.sttp.asynchttpclient.{
AsyncHttpClientHandler,
MonadAsyncError
@@ -43,7 +44,7 @@ object MonixAsyncHttpClientHandler {
* global scheduler.
*/
def apply()(implicit s: Scheduler = Scheduler.Implicits.global)
- : MonixAsyncHttpClientHandler =
+ : SttpHandler[Task, Observable[ByteBuffer]] =
new MonixAsyncHttpClientHandler(new DefaultAsyncHttpClient(),
closeClient = true)
@@ -53,7 +54,7 @@ object MonixAsyncHttpClientHandler {
*/
def usingConfig(cfg: AsyncHttpClientConfig)(implicit s: Scheduler =
Scheduler.Implicits.global)
- : MonixAsyncHttpClientHandler =
+ : SttpHandler[Task, Observable[ByteBuffer]] =
new MonixAsyncHttpClientHandler(new DefaultAsyncHttpClient(),
closeClient = true)
@@ -63,7 +64,7 @@ object MonixAsyncHttpClientHandler {
*/
def usingClient(client: AsyncHttpClient)(implicit s: Scheduler =
Scheduler.Implicits.global)
- : MonixAsyncHttpClientHandler =
+ : SttpHandler[Task, Observable[ByteBuffer]] =
new MonixAsyncHttpClientHandler(client, closeClient = false)
}