Requesting one element at a time would lead to low-to-no concurrency and high overhead per element. Check input buffer size in Attributes.
-- Cheers, √ On 26 Jul 2015 17:50, "David Pinn" <dp...@byandlarge.net> wrote: > I think this could happen if a stage immediately requests the next element > once it starts working on a received element. Is that the case? > > On Sunday, 26 July 2015 23:39:00 UTC+10, David Pinn wrote: >> >> b) the stream processes one more element than I expect it to. >> >> The source under test spits out the integer 4, even though the ticks were >> cancelled while the integer 1 was being doubled. >> > -- >>>>>>>>>> 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 http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
