I'm attempting to implement a flow graph like so:
unzip.out0 ~> someLogic ~> router.in
router.out1[C] ~> zipA.in0
router.out2[D] ~> zipB.in0
unzip.out1 ~> balance
balance ~> ~> zipA.in1
balance ~> ~> zipB.in1
The shape of the graph is inlet (A, B) from unzip.in and two outlets of (C,
B) and (D, B) from zipA and zipB. The idea is that the logic in `someLogic`
really doesn't need to know about B so rather than piping it through, we'll
just merge it back at the end. Keeping the pairs from the original input
tuple together is important. `router`'s behavior is to send only to one
output depending on the input data.
The problem is that balance will send to one of the zips to fill its
initial buffer and not necessarily the one that received data from
`router`.
I worked around the issue by zipping before `router` but that makes
`router` slightly more complex.
Is there a way to implement something like this with Akka Streams?
Thanks
--
>>>>>>>>>> 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.
