Skip to content

Instantly share code, notes, and snippets.

@adamw
Created October 21, 2020 19:52
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save adamw/bb212ef2669269c6ffe3cf2d0bc5ab63 to your computer and use it in GitHub Desktop.
Save adamw/bb212ef2669269c6ffe3cf2d0bc5ab63 to your computer and use it in GitHub Desktop.
import monix.reactive.Observable
import sttp.capabilities.monix.MonixStreams
object Test extends App {
import sttp.client3._
import monix.execution.Scheduler.Implicits.global
val b = AsyncHttpClientMonixBackend().runSyncUnsafe()
basicRequest.post(uri"http://198.51.100.0").streamBody(MonixStreams)(Observable.empty).send(b).runSyncUnsafe()
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment