Hello Ian, replies in-line :-) I'm recently read about reactive streams, and want to know some more about > it. > Awesome, you're in the right place then :-)
> how does one deal with time. specifically how do I set up a periodic > scheduler to tell the flow that it's time to emit results. (and ideally > allow my service to set the time based on input records and not use system > time, so I can do stuff like replaying logs) > The first time based operators have been merged just by the end of last week actually - https://github.com/akka/akka/commit/0fb9a92efcc4cf707bfe6fdc92dcf0ad4225209e Akka Streams are still in very early stages as you can see, but having a look at the above code may help you out. > and secondly how do I scale these flows to work over multiple machines. > Ideally I'd like to just hand a dozen machines to Akka and say 'go wild' > and let it figure it all out, but failing that how can I allocate resources > to a producer? > The streams are currently "in jvm". While streaming over the network is our goal in the long run (and providing back-pressure among these nodes) these are still "coming". We do have an TCP stream implementation, but that's not exactly what you're asking for. I hope this helps, cheers! -- Cheers, Konrad 'ktoso' Malawski hAkker - Typesafe, Inc <http://scaladays.org> -- >>>>>>>>>> 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.
