tests/src/test/scala/com/softwaremill/sttp/streaming/AsyncHttpClientMonixStreamingTests.scala


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

package com.softwaremill.sttp.streaming

import java.nio.ByteBuffer

import com.softwaremill.sttp.SttpHandler
import com.softwaremill.sttp.asynchttpclient.monix.AsyncHttpClientMonixHandler
import monix.eval.Task
import monix.reactive.Observable

class AsyncHttpClientMonixStreamingTests extends MonixBaseHandler {

  import monix.execution.Scheduler.Implicits.global

  override implicit val handler: SttpHandler[Task, Observable[ByteBuffer]] =
    AsyncHttpClientMonixHandler()

}