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 col
Hi Alexey,
On Thu, Jan 22, 2015 at 4:15 AM, Alexey Romanchuk <
alexey.romanc...@gmail.com> wrote:
> 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 i
It is exactly what I have tried to achieve! You guys did amazing work with
all akka streams. Thanks! :)
четверг, 22 января 2015 г., 14:43:52 UTC+6 пользователь drewhk написал:
>
> Hi Alexey,
>
>
>
> On Thu, Jan 22, 2015 at 4:15 AM, Alexey Romanchuk > wrote:
>
>> Hey!
>>
>> I have a stream that p
Hi Alexey,
On Thu, Jan 22, 2015 at 12:31 PM, Alexey Romanchuk <
alexey.romanc...@gmail.com> wrote:
> It is exactly what I have tried to achieve! You guys did amazing work with
> all akka streams. Thanks! :)
>
You might be also interested in this ticket:
https://github.com/akka/akka/issues/16610