Hi all,
Finally I found the way to do it. It wasn't easy to understand the API for
the FlowGraph.closed()
http://doc.akka.io/api/akka-stream-and-http-experimental/1.0/index.html#akka.stream.scaladsl.FlowGraph$
function, but taking a deeper look I understood that it needs a
*combinedMat*
Thanks for your response Roland,
I've been trying to run the test as you suggested but I had no luck. The
test works if I do something like this (I'm testing only the first output):
val out = FlowGraph.closed(collector[Event]) { implicit builder = out =
val eif = builder.add(eventInputFlow)
Hi Gabriel,
testing such a Graph as a black box is rather simple: just attach a Source
that emits the test inputs and attach a Sink to each output that collects
all emitted elements (e.g. using
Flow[...].grouped(1000).toMat(Sink.head)(Keep.right)). When running that
flow, the output Futures will
