I would like to build a custom GraphStage that essentially filters out 
elements based on a comparison made against the result of a Future and 
would like to retain this value for future elements.  Additionally, I would 
also like to preserve the order in which elements pass through filter.  My 
current implementation uses mapAsync with parallelism factor set to 1 and 
an actor that executes the future and maintains state.  It pipes results 
back to self for processing and then sends it back to the temp sender 
created in the mapAsync call.  Is this approach appropriate?

Would you be able to provide any high level guidance on how to accomplish 
this in a custom GraphStage?  I think I grasp how AsyncCallbacks work but 
am not 100% sure about how to guarantee order.  If I execute separate 
Futures for each upstream push, there is the chance they may finish out of 

Any advice is greatly appreciated - thank you in advance!

>>>>>>>>>>      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 akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Reply via email to