THANK YOU for your responses; and very helpful Endre to explain! Need to Google up those JS interfaces for async and sync!
So, then, if you've got a system of remote services talking to each other; you pretty much need to be coding to interfaces which support the Reactive protocol on (both) sides of the Network connection; otherwise the backpressure mechanism will fail, I guess. Thanks! D On Wednesday, September 21, 2016 at 11:01:12 AM UTC-7, Dagny T wrote: > > > Just wanted to check with folks if I had the correct implementation for > how to protect from blowing up memory when working with Akka Streams. > > I've merged a Lightbend Blog post's code, with the latest API changes for > Akka v2.4.9, and the latest documentation about buffered streams in the > v2.4.9 API Docs. > > However, none of those explain these questions I have. Please see > question comments, regarding the code snippet below it! THANKS in advance > for any insights! > > // TODO 3: MODIFIED to calling buffered API within Graph mapping -- check > assumptions! > // - where INTERNAL Akka implementation calls onNext() to get next > BUFFERED batch, > // so you don't have to worry about it as a DEV? > // - NUMERIC bound of 10 refers to NUMBER of elements (of possibly > complex types) on a > // UNIFORM-ELEMENT-TYPED stream, rather than Bytes, right? > // - if source produces N < BUFFER_MAX elements; then those are > simply passed through the pipeline without > // waiting to accumulate BUFFER_MAX elements > // > > > inputSource.buffer(10, OverflowStrategy.dropHead) ~> f1 ~> ... > > -- >>>>>>>>>> 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.
