Hi,
I am quite newbie with akka-streams, and haven't yet understood how the
Flow API integrates with the reactive streams API and the actors API,
especially with respect to back-pressure.
I have a flow that is designed like so:
FlowGraph { implicit b =>
Source ~> Flow1 ~> Flow2 ~> Sink
}
with the Source ~> Flow1 part producing elements faster than Flow2 ~> Sink
can consume them, resulting in RAM exhaustion.
What would be the preferred way of dealing with this situation? How can the
downstream part notify the upstream part that it needs to slow down, and
how can the latter react to that?
It looks like ActorPublisher and ActorSuscriber could be part of the
solution, but I haven't figured out how to integrate them with the existing
Flows.
Thanks 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 [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.
