aboutsummaryrefslogtreecommitdiff
path: root/async-http-client-handler
diff options
context:
space:
mode:
authoradamw <adam@warski.org>2017-07-28 15:28:15 +0200
committeradamw <adam@warski.org>2017-07-28 15:28:15 +0200
commitdf1fff3b2c2f8a0a7cbc3c2101c810358ec49920 (patch)
treead4aeaf6942e718a1722e226741d14552e9e7bd8 /async-http-client-handler
parent8c7945ea87371d02906b84c45dc2d3b92f815306 (diff)
downloadsttp-df1fff3b2c2f8a0a7cbc3c2101c810358ec49920.tar.gz
sttp-df1fff3b2c2f8a0a7cbc3c2101c810358ec49920.tar.bz2
sttp-df1fff3b2c2f8a0a7cbc3c2101c810358ec49920.zip
Using a custom URI class
Diffstat (limited to 'async-http-client-handler')
-rw-r--r--async-http-client-handler/future/src/main/scala/com/softwaremill/sttp/asynchttpclient/future/FutureAsyncHttpClientHandler.scala6
-rw-r--r--async-http-client-handler/src/main/scala/com/softwaremill/sttp/asynchttpclient/AsyncHttpClientHandler.scala7
2 files changed, 5 insertions, 8 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 b0a36f9..5d71511 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
@@ -38,8 +38,7 @@ object FutureAsyncHttpClientHandler {
* e.g. mapping responses. Defaults to the global execution
* context.
*/
- def apply()(
- implicit ec: ExecutionContext = ExecutionContext.Implicits.global)
+ def apply()(implicit ec: ExecutionContext = ExecutionContext.Implicits.global)
: SttpHandler[Future, Nothing] =
new FutureAsyncHttpClientHandler(new DefaultAsyncHttpClient(),
closeClient = true)
@@ -72,8 +71,7 @@ private[future] class FutureMonad(implicit ec: ExecutionContext)
override def map[T, T2](fa: Future[T], f: (T) => T2): Future[T2] = fa.map(f)
- override def flatMap[T, T2](fa: Future[T],
- f: (T) => Future[T2]): Future[T2] =
+ override def flatMap[T, T2](fa: Future[T], f: (T) => Future[T2]): Future[T2] =
fa.flatMap(f)
override def async[T](
diff --git a/async-http-client-handler/src/main/scala/com/softwaremill/sttp/asynchttpclient/AsyncHttpClientHandler.scala b/async-http-client-handler/src/main/scala/com/softwaremill/sttp/asynchttpclient/AsyncHttpClientHandler.scala
index d634446..cd10735 100644
--- a/async-http-client-handler/src/main/scala/com/softwaremill/sttp/asynchttpclient/AsyncHttpClientHandler.scala
+++ b/async-http-client-handler/src/main/scala/com/softwaremill/sttp/asynchttpclient/AsyncHttpClientHandler.scala
@@ -28,10 +28,9 @@ import org.reactivestreams.{Publisher, Subscriber, Subscription}
import scala.collection.JavaConverters._
import scala.language.higherKinds
-abstract class AsyncHttpClientHandler[R[_], S](
- asyncHttpClient: AsyncHttpClient,
- rm: MonadAsyncError[R],
- closeClient: Boolean)
+abstract class AsyncHttpClientHandler[R[_], S](asyncHttpClient: AsyncHttpClient,
+ rm: MonadAsyncError[R],
+ closeClient: Boolean)
extends SttpHandler[R, S] {
override def send[T](r: Request[T, S]): R[Response[T]] = {