diff options
Diffstat (limited to 'okhttp-handler/monix/src')
| -rw-r--r-- | okhttp-handler/monix/src/main/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixHandler.scala | 9 |
1 files changed, 6 insertions, 3 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 31f4546..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 @@ -14,6 +14,7 @@ import okhttp3.{MediaType, OkHttpClient, RequestBody => OkHttpRequestBody} import okio.BufferedSink import scala.concurrent.Future +import scala.concurrent.duration.FiniteDuration import scala.util.{Failure, Success, Try} class OkHttpMonixHandler private (client: OkHttpClient, closeClient: Boolean)( @@ -84,10 +85,12 @@ object OkHttpMonixHandler { implicit s: Scheduler): SttpHandler[Task, Observable[ByteBuffer]] = new FollowRedirectsHandler(new OkHttpMonixHandler(client, closeClient)(s)) - def apply()(implicit s: Scheduler = Scheduler.Implicits.global) + def apply(connectionTimeout: FiniteDuration = SttpHandler.DefaultConnectionTimeout)( + implicit s: Scheduler = Scheduler.Implicits.global) : SttpHandler[Task, Observable[ByteBuffer]] = - OkHttpMonixHandler(OkHttpHandler.buildClientNoRedirects(), - closeClient = true)(s) + OkHttpMonixHandler( + OkHttpHandler.defaultClient(DefaultReadTimeout.toMillis, connectionTimeout.toMillis), + closeClient = true)(s) def usingClient(client: OkHttpClient)(implicit s: Scheduler = Scheduler.Implicits.global) |