Hi all,
I struggle for a while with implementing a multiplexer processing stage. An additional complication is, that the multiplexer processing stage should be built incrementally, i.e. the same multiplexer stage should be used at various points in the whole processing graph and at each point a unique "channel number" should be assigned to that point automatically. I try to illustrate the usage by a little ASCII art:
^ |
| |
a b
| |
_|__v_
| |
--1i-->| |--1o-->
--2i-->| |--2o-->
| |
--------
The Multiplexer should multiplex several inputs (1i, 2i, ...) over a single flow(a,b) into matching outputs (o1, o2, ...). The basic logic can be implemented straightforwardly with the help of the Merge and Broadcast stage by augmenting the payload by a channel number while it is transmitted over the common flow(a,b).
Usage example:
--p--> | M | --q--> // first reference, automatically assign channel number 0; the common flow(a,b) is not mentioned here at all
--r--> | M | --s--> // second reference, automatically asssign channel number 1; the common flow(a,b) is not mentioned here at all
However, I do not know how to build up such a Multiplexer incrementally. (The Merge and Broadcast stages must know their number of links in advance.) If possible then the solution should also support that the same multiplexer can also be used in different subgraphs that were constructed by the GraphDSL separately.
Can anybody help?
TIA
Stefan
>>>>>>>>>> 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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
