diff options
author | adamw <adam@warski.org> | 2017-07-24 12:26:50 +0200 |
---|---|---|
committer | adamw <adam@warski.org> | 2017-07-24 12:26:50 +0200 |
commit | 986f6ff409b91230924508eafa7e4c077358dfed (patch) | |
tree | f665f48d6e99e8e0dd5c907638c2fda876a41641 /async-http-client-handler/future/src | |
parent | ccd2c4b1d53bf68e04ff1f8bca032d870494d9a8 (diff) | |
download | sttp-986f6ff409b91230924508eafa7e4c077358dfed.tar.gz sttp-986f6ff409b91230924508eafa7e4c077358dfed.tar.bz2 sttp-986f6ff409b91230924508eafa7e4c077358dfed.zip |
Adding missing implicit EC to Future/AsyncHttpClient handler
Diffstat (limited to 'async-http-client-handler/future/src')
-rw-r--r-- | async-http-client-handler/future/src/main/scala/com/softwaremill/sttp/asynchttpclient/future/FutureAsyncHttpClientHandler.scala | 23 |
1 files changed, 17 insertions, 6 deletions
diff --git a/async-http-client-handler/future/src/main/scala/com/softwaremill/sttp/asynchttpclient/future/FutureAsyncHttpClientHandler.scala b/async-http-client-handler/future/src/main/scala/com/softwaremill/sttp/asynchttpclient/future/FutureAsyncHttpClientHandler.scala index 41fcf68..adc679e 100644 --- a/async-http-client-handler/future/src/main/scala/com/softwaremill/sttp/asynchttpclient/future/FutureAsyncHttpClientHandler.scala +++ b/async-http-client-handler/future/src/main/scala/com/softwaremill/sttp/asynchttpclient/future/FutureAsyncHttpClientHandler.scala @@ -12,12 +12,23 @@ import org.asynchttpclient.{ import scala.concurrent.{ExecutionContext, Future, Promise} -class FutureAsyncHttpClientHandler(asyncHttpClient: AsyncHttpClient)( - implicit ec: ExecutionContext = ExecutionContext.Implicits.global) - extends AsyncHttpClientHandler[Future](asyncHttpClient, new FutureMonad()) { - - def this() = this(new DefaultAsyncHttpClient()) - def this(cfg: AsyncHttpClientConfig) = this(new DefaultAsyncHttpClient(cfg)) +class FutureAsyncHttpClientHandler private (asyncHttpClient: AsyncHttpClient)( + implicit ec: ExecutionContext) + extends AsyncHttpClientHandler[Future](asyncHttpClient, new FutureMonad()) + +object FutureAsyncHttpClientHandler { + def apply()( + implicit ec: ExecutionContext = ExecutionContext.Implicits.global) + : FutureAsyncHttpClientHandler = + new FutureAsyncHttpClientHandler(new DefaultAsyncHttpClient()) + def usingConfig(cfg: AsyncHttpClientConfig)( + implicit ec: ExecutionContext = ExecutionContext.Implicits.global) + : FutureAsyncHttpClientHandler = + new FutureAsyncHttpClientHandler(new DefaultAsyncHttpClient()) + def usingClient(client: AsyncHttpClient)(implicit ec: ExecutionContext = + ExecutionContext.Implicits.global) + : FutureAsyncHttpClientHandler = + new FutureAsyncHttpClientHandler(client) } private[future] class FutureMonad(implicit ec: ExecutionContext) |