Re: [akka-user] [akka-streams] StreamConverters.fromOutputStream(..) stops processing messages

Thanks for the tip! I've found the culpit -- threads were not blocked, they all were waiting for read from corresponding input streams, separate dispatcher for intput and output streams resolves this problem. Still, I'm not comfortable with so many thread blocking on read, so I'll try to

Re: [akka-user] [akka-streams] StreamConverters.fromOutputStream(..) stops processing messages

It could be that all of the threads are blocked in the default-blocking-io-dispatcher Make a thread dump and take a look if that is the case. On Mon, May 15, 2017 at 8:17 PM Alexey Shuksto wrote: > Hello hAkkers, > > Our app spawns multiple external processes (via >

[akka-user] [akka-streams] StreamConverters.fromOutputStream(..) stops processing messages

Hello hAkkers, Our app spawns multiple external processes (via java.util.Runtime.exec(..)) and then writes to STDIN of such processes via: ``` StreamConverters .fromOutputStream(() => process.getOutputStream, autoFlush = true) .runWith(MergeHub.source[]) ``` MergeHub is attached to output