aboutsummaryrefslogtreecommitdiff
path: root/async-http-client-handler/future/src/main/scala/com/softwaremill
diff options
context:
space:
mode:
authoradamw <adam@warski.org>2017-07-24 12:26:50 +0200
committeradamw <adam@warski.org>2017-07-24 12:26:50 +0200
commit986f6ff409b91230924508eafa7e4c077358dfed (patch)
treef665f48d6e99e8e0dd5c907638c2fda876a41641 /async-http-client-handler/future/src/main/scala/com/softwaremill
parentccd2c4b1d53bf68e04ff1f8bca032d870494d9a8 (diff)
downloadsttp-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/main/scala/com/softwaremill')
-rw-r--r--async-http-client-handler/future/src/main/scala/com/softwaremill/sttp/asynchttpclient/future/FutureAsyncHttpClientHandler.scala23
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)