Skip to content

Instantly share code, notes, and snippets.

/post.scala

Created April 18, 2017 13:11
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 anonymous/877e6bfd597967e38f827f199937a779 to your computer and use it in GitHub Desktop.
Save anonymous/877e6bfd597967e38f827f199937a779 to your computer and use it in GitHub Desktop.
Download ZIP
the description for this gist
Raw
post.scala
source.sendNext(ByteString("anything"))
sink.request(1)
// Here we receive CONNECT message
transportInProbe.requestNext()
// Here we pull `bytesOut` of ProxyStage
transportInProbe.request(1)
// Here we push to `bytesIn` of ProxyStage
transportOutProbe.sendNext(ByteString("OK"))
val recv = transportInProbe.expectNext()
transportOutProbe.sendNext(recv)
sink.expectNext(ByteString("anything"))
source.sendComplete()
transportOutProbe.sendComplete()
sink.expectComplete()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment