Hi, For BroadcastHub, I can have a dynamic set of consumers; then the data from Source will be broadcasted to all of the consumers which join the hub. My user case is a bit different. Supposedly, I have a infinitely datasource such as Source(1 to n). I want to have something like CustomBalancerHub. There might be several consumers. Each consumer has an type; For "EvenConsumer"; it expects to receive ONLY even numbers; for "OddConsumer", it expects to receive ONLY odd number; If at the beginning; old EvenConsumer join the Hub; even number from the datasource will be sent to evenconsumer; where odd number from data will be ignore; later on, OddConsumer might joined, and it will receive odd number from data source.
The idea is that there might be several different type of consumers and I want the system to be back-pressued. Can I implement a custom broadcast Hub to do so? I can't use GraphDSL to implement a custom GraphState because according to the docs "The Graph DSL does not allow to represent this, all connections of the graph must be known in advance and must be connected upfront" Is there any way to solve this? 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 https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
