Hey! I have a stream that process incoming messages, assemble big message "pack" and send it to other system via network. Incoming messages are relatively small and I use big buffers to improve throughput for all stages related to these small messages. At the very end of stream I have "message collector" which aggregates messages and periodically produces message "packs" which must be sent via network.
System looks like this: (Input) -> (Complex flow for small messages) -> (Aggregator) -> (Network sender) I increased buffer size to 128 to improve throughput, but the problem is in network sender. Network sender can resend data several times in case of network failure. I want to force only 1 element buffer before network sender to perform effective backpressure to input. In case of same size buffer size stream can be flooded with lot of huge aggregators packages. I know that there is "buffer" flow combinator, but it looks like it work only if I want to increase buffer size before some stage, but does not work for decreasing buffer size. Could you advise right way to achieve this kind of backpressure? Thanks! -- >>>>>>>>>> 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.
