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
// what we want to test:
val flowUnderTest = Flow[Int].map(n => n * n)
// source and sink probes are returned as materialized values:
val (source, sink) = TestSource.probe[Int]
.via(flowUnderTest)
.toMat(TestSink.probe)(Keep.both)
.run()
// now we can use source and sink to
source.sendNext(3)
sink.requestNext(9)
source.sendComplete()
sink.expectComplete()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment