From 4fb65e25f528cb29a16d575fef7ecfd79c6b9fb9 Mon Sep 17 00:00:00 2001 From: adamw Date: Thu, 3 Aug 2017 14:29:33 +0200 Subject: Fix 2.11 compile --- .../scala/com/softwaremill/sttp/okhttp/OkHttpClientHandler.scala | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'okhttp-client-handler/src') diff --git a/okhttp-client-handler/src/main/scala/com/softwaremill/sttp/okhttp/OkHttpClientHandler.scala b/okhttp-client-handler/src/main/scala/com/softwaremill/sttp/okhttp/OkHttpClientHandler.scala index b18fdbb..cb1103b 100644 --- a/okhttp-client-handler/src/main/scala/com/softwaremill/sttp/okhttp/OkHttpClientHandler.scala +++ b/okhttp-client-handler/src/main/scala/com/softwaremill/sttp/okhttp/OkHttpClientHandler.scala @@ -87,7 +87,9 @@ abstract class OkHttpClientHandler[R[_], S](client: OkHttpClient) case ResponseAsByteArray => responseMonad.unit(res.body().bytes()) case MappedResponseAs(raw, g) => responseMonad.map(readResponseBody(res, raw), g) - case ResponseAsStream() => responseMonad.error(new IllegalStateException("Streaming isn't supported")) + case ResponseAsStream() => + responseMonad.error( + new IllegalStateException("Streaming isn't supported")) } } } @@ -127,7 +129,7 @@ class OkHttpFutureClientHandler private (client: OkHttpClient)( promise.success(readResponse(response, r.responseAs)) }) - promise.future.flatten + responseMonad.flatten(promise.future) } override def responseMonad: MonadError[Future] = new FutureMonad -- cgit v1.2.3