The back pressure is propagated to the client thanks to TCPs built in mechanisms for this - on the server side we simply do not read from the socket until demand is available, which causes the back pressure to be propagated properly.
Konrad, So if we are *not* using a congestion control aware protocol such as TCP, the back pressure won't work propagate though network boundaries. Correct? If you use a protocol that is unable to perform congestion control, you will not have congestion control over that medium - correct :-) There is an effort to implement the reactive streams semantics to an on-the-wire protocol, https://github.com/reactive-streams/reactive-streams-io but it’s not yet under heavy development. In this case both ends need to understand and speak the reactive streams protocol on wire level. It would allow using any kind of transport layer - we could ditch TCP then. Is there a way to build this easily using Akka-streams/reactive-streams ? With TCP it just works. For the network protocol see the link above, there will be work done around it soon. -- Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe -- >>>>>>>>>> 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.
