blob: 27a4517f37ca8514628e3fdb331a95eed7ae05b6 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
package com.softwaremill.sttp.streaming
import java.nio.ByteBuffer
import com.softwaremill.sttp.SttpBackend
import com.softwaremill.sttp.impl.monix.MonixTestStreamingBackend
import com.softwaremill.sttp.okhttp.monix.OkHttpMonixBackend
import monix.eval.Task
import monix.reactive.Observable
class OkHttpMonixStreamingTests extends MonixTestStreamingBackend {
import monix.execution.Scheduler.Implicits.global
override implicit val backend: SttpBackend[Task, Observable[ByteBuffer]] =
OkHttpMonixBackend()
}
|