I can't figure out a clean way to implement something like the following with akka-streams:
1. Pull work item from a large-but-finite queue 2. Wait for a resource to be available from a small and finite pool [blocking, so probably evil?] 3. Do a computation using work item and resource. [ideally there will be many 3's running in parallel] 4. Return resource to pool 5. Send result of computation to some kind of output The biggest issue is the interaction between steps 4 and 2. I cannot figure out how to create a cycle that would feed resources back to the pool. I also cannot figure out a clean way to implement step 2. Source.unfoldResource with explicit blocking in my read function seems like the best option. Is there a good way to build this type of flow? Thanks, -John -- >>>>>>>>>> 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.
