diff options
Diffstat (limited to 'okhttp-client-handler/src')
-rw-r--r-- | okhttp-client-handler/src/main/scala/com/softwaremill/sttp/okhttp/OkHttpClientHandler.scala | 6 |
1 files changed, 4 insertions, 2 deletions
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 |