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
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
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