aboutsummaryrefslogtreecommitdiff
path: root/async-http-client-handler/monix/src/main
diff options
context:
space:
mode:
authoradamw <adam@warski.org>2017-08-31 14:40:29 +0200
committeradamw <adam@warski.org>2017-08-31 14:40:29 +0200
commit9ec0994878856743e54c4d1a38c0c80b318d7be7 (patch)
treefb55121a0bc90325369a4c1fa8e73da9c35c37a4 /async-http-client-handler/monix/src/main
parent71f6a1eeee412045cc08ce8894194573362cb8f0 (diff)
downloadsttp-9ec0994878856743e54c4d1a38c0c80b318d7be7.tar.gz
sttp-9ec0994878856743e54c4d1a38c0c80b318d7be7.tar.bz2
sttp-9ec0994878856743e54c4d1a38c0c80b318d7be7.zip
Change MonadError syntax to improve type inference
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/AsyncHttpClientMonixHandler.scala11
1 files changed, 8 insertions, 3 deletions
diff --git a/async-http-client-handler/monix/src/main/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixHandler.scala b/async-http-client-handler/monix/src/main/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixHandler.scala
index 1ef3973..786f176 100644
--- a/async-http-client-handler/monix/src/main/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixHandler.scala
+++ b/async-http-client-handler/monix/src/main/scala/com/softwaremill/sttp/asynchttpclient/monix/AsyncHttpClientMonixHandler.scala
@@ -2,7 +2,12 @@ package com.softwaremill.sttp.asynchttpclient.monix
import java.nio.ByteBuffer
-import com.softwaremill.sttp.{MonadAsyncError, SttpHandler, Utf8, concatByteBuffers}
+import com.softwaremill.sttp.{
+ MonadAsyncError,
+ SttpHandler,
+ Utf8,
+ concatByteBuffers
+}
import com.softwaremill.sttp.asynchttpclient.AsyncHttpClientHandler
import monix.eval.Task
import monix.execution.{Cancelable, Scheduler}
@@ -77,9 +82,9 @@ object AsyncHttpClientMonixHandler {
private[monix] object TaskMonad extends MonadAsyncError[Task] {
override def unit[T](t: T): Task[T] = Task.now(t)
- override def map[T, T2](fa: Task[T], f: (T) => T2): Task[T2] = fa.map(f)
+ override def map[T, T2](fa: Task[T])(f: (T) => T2): Task[T2] = fa.map(f)
- override def flatMap[T, T2](fa: Task[T], f: (T) => Task[T2]): Task[T2] =
+ override def flatMap[T, T2](fa: Task[T])(f: (T) => Task[T2]): Task[T2] =
fa.flatMap(f)
override def async[T](