Problems with processing fast occurring elements in stream

[ouven]

Hi, without knowing much about your use case, for me it sounds like you could use flat_map to split multi lines into several messages and reinject each into the stream.