I'm just getting started with Akka & Akka Streams, and trying to create a little PoC for my project.
I want to create a flow graph like https://drive.google.com/file/d/0B8Cu6-NkpXpCX1BuUEVtY3VPVzg/view?usp=sharing I'm not sure how to implement the 'Data Extractor' stage. My problem is that I want start consuming the httpresponse and start generating events from it, but 'buffer' the events until I can tell whether the request was successful or not (by looking at the buffered events), and if there was an authentication error (or rate-limit error, not show in the diagram), return an object signifying that, otherwise returning a source that returns the buffered events, followed by any subsequent events, not yet buffered (so, I don't want to consume the entire response before returning the source). Is there anything built-in that would help me achieve this, or do I need to create a custom graphstage + custom source implementation? Thanks, Matthew Wozniczka -- >>>>>>>>>> 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.
