Hi hakkers!

I found difficult to test a Partial Flow Graph. I can test the different 
single pieces, but not the whole partial flow. I'm separating the flows 
depending on it's functionality and I wish to test every partial flow like 
a black box.

For instance, given the following partial flow:

lazy val eventInputFlow = FlowGraph.partial() { implicit builder =>
  val headerEnricherFlow = builder.add(Flow[Event] map (e => applyHeaders(e
)))
  val eventFilter = builder.add(eventFilterFlow)
  val eventOriginFilter = builder.add(eventOriginFilterFlow)
  val eventDeletedLogger = builder.add(eventDeletedLoggerFlow)
  val sinkIgnore = builder.add(Sink.ignore)

  headerEnricherFlow ~> eventFilter
  eventFilter.out(0) ~> eventOriginFilter
  eventFilter.out(1) ~> eventDeletedLogger ~> sinkIgnore

  UniformFanOutShape(headerEnricherFlow.inlet, eventOriginFilter.out(0), 
eventOriginFilter.out(1))
}.named("eventInputFlow")

It would be nice to test the 1 Input and the 2 outputs of this graph.

I don't really know how to achieve this.

Any help would be appreciated.

Thanks,
Gabriel.

-- 
>>>>>>>>>>      Read the docs: http://akka.io/docs/
>>>>>>>>>>      Check the FAQ: 
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>>      Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Reply via email to