aboutsummaryrefslogtreecommitdiff
path: root/okhttp-backend/monix
diff options
context:
space:
mode:
Diffstat (limited to 'okhttp-backend/monix')
-rw-r--r--okhttp-backend/monix/src/main/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixBackend.scala9
1 files changed, 4 insertions, 5 deletions
diff --git a/okhttp-backend/monix/src/main/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixBackend.scala b/okhttp-backend/monix/src/main/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixBackend.scala
index 4b24e65..db36f32 100644
--- a/okhttp-backend/monix/src/main/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixBackend.scala
+++ b/okhttp-backend/monix/src/main/scala/com/softwaremill/sttp/okhttp/monix/OkHttpMonixBackend.scala
@@ -85,13 +85,12 @@ object OkHttpMonixBackend {
implicit s: Scheduler): SttpBackend[Task, Observable[ByteBuffer]] =
new FollowRedirectsBackend(new OkHttpMonixBackend(client, closeClient)(s))
- def apply(connectionTimeout: FiniteDuration =
- SttpBackend.DefaultConnectionTimeout)(
+ def apply(options: SttpBackendOptions = SttpBackendOptions.Default)(
implicit s: Scheduler = Scheduler.Implicits.global)
: SttpBackend[Task, Observable[ByteBuffer]] =
- OkHttpMonixBackend(OkHttpBackend.defaultClient(DefaultReadTimeout.toMillis,
- connectionTimeout.toMillis),
- closeClient = true)(s)
+ OkHttpMonixBackend(
+ OkHttpBackend.defaultClient(DefaultReadTimeout.toMillis, options),
+ closeClient = true)(s)
def usingClient(client: OkHttpClient)(implicit s: Scheduler =
Scheduler.Implicits.global)