diff options
| author | Piotr Gabara <piotr.gabara@hotmail.com> | 2017-09-06 19:09:16 +0200 |
|---|---|---|
| committer | Piotr Gabara <piotr.gabara@hotmail.com> | 2017-09-06 19:20:17 +0200 |
| commit | 6874e55a316e4fe8a650efd3a849814a91bba8cb (patch) | |
| tree | e22fa85abb61805b2d8f363b0e55eac1d60a94f3 /okhttp-handler/monix/src/main | |
| parent | e82346820797bb2d80d0fada7f17c5880871edce (diff) | |
| download | sttp-6874e55a316e4fe8a650efd3a849814a91bba8cb.tar.gz sttp-6874e55a316e4fe8a650efd3a849814a91bba8cb.tar.bz2 sttp-6874e55a316e4fe8a650efd3a849814a91bba8cb.zip | |
Post review changes
Diffstat (limited to 'okhttp-handler/monix/src/main')
| -rw-r--r-- | okhttp-handler/monix/src/main/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixHandler.scala | 11 |
1 files changed, 3 insertions, 8 deletions
diff --git a/okhttp-handler/monix/src/main/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixHandler.scala b/okhttp-handler/monix/src/main/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixHandler.scala index 608d499..8d20bad 100644 --- a/okhttp-handler/monix/src/main/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixHandler.scala +++ b/okhttp-handler/monix/src/main/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixHandler.scala @@ -1,7 +1,7 @@ package com.softwaremill.sttp.okhttp.monix import java.nio.ByteBuffer -import java.util.concurrent.{ArrayBlockingQueue, TimeUnit} +import java.util.concurrent.ArrayBlockingQueue import com.softwaremill.sttp.{SttpHandler, _} import com.softwaremill.sttp.okhttp.{OkHttpAsyncHandler, OkHttpHandler} @@ -89,13 +89,8 @@ object OkHttpMonixHandler { implicit s: Scheduler = Scheduler.Implicits.global) : SttpHandler[Task, Observable[ByteBuffer]] = OkHttpMonixHandler( - OkHttpHandler - .defaultBuilder() - .connectTimeout(connectionTimeout.toMillis, TimeUnit.MILLISECONDS) - .readTimeout(SttpHandler.DefaultConnectionTimeout.toMillis, TimeUnit.MILLISECONDS) - .build(), - closeClient = true - )(s) + OkHttpHandler.defaultClient(DefaultReadTimeout.toMillis, connectionTimeout.toMillis), + closeClient = true)(s) def usingClient(client: OkHttpClient)(implicit s: Scheduler = Scheduler.Implicits.global) |