Skip to content

Instantly share code, notes, and snippets.

/post.scala

Created Apr 18, 2017
Embed
What would you like to do?
the description for this gist
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