Hello, I hope this is the correct group for this question... I have an existing pipe-line process written in Actor using the "Work Pulling" pattern.
http://www.michaelpollmeier.com/akka-work-pulling-pattern/ The first stage of my pipeline is a database query written in Slick. The result is very big, and will not fit in memory. Therefore, I want to use the new Slick streaming interface. http://slick.typesafe.com/doc/3.0.0/dbio.html#streaming However, Reactive Streams seem to be at odds with Work-Pulling. How can I pause the stream until my Actors are ready to pull some more data? How do I interface a Reactive Stream to a Work-Pulling system? Is the a document, example code, slides, or idiom that deals with this? Many thanks P -- >>>>>>>>>> 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.
