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
// TODO 3: MODIFIED to calling buffered API within Graph mapping -- check
// - where INTERNAL Akka implementation calls onNext() to get next
// 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:
>>>>>>>>>> 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 post to this group, send email to firstname.lastname@example.org.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.