[akka-user] Split stream in arbitrary number of sinks

2016-05-04 Thread Filippo De Luca
Hi, I was looking at the reactive tweets stream example when the stream is broadcasted to two downstream sinks. I need to do something similar: I have a Source of rows and I want to distribute these row across several substreams based on a column value. The issue is that I don't know the number

[akka-user] Split Stream

2015-03-15 Thread Jim Hazen
Have you looked into writing a custom router component? -- 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

[akka-user] Split Stream

2015-03-13 Thread Andrii Liubimov
Hi, I am using Akka Streams API for receiving and storing messages to DB. I like flow control feature of Akka Streams and think it is perfectly fit my requirements. 99% of objects in stream should be routed to persistence, however 1% is requests, that has to be routed to processor. I would