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 <seig...@gmail.com> wrote:
> 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 stream to prevent closing of such stream
> after one of client done writing to it.
>
> While there are up to, say, four external processes everything is working
> fine, but as soon as they number increases, OutputStreamSubscriber just
> stops to request next elements for all of them.
> I've checked via adding `.confate` for incoming ByteStrings -- buffer just
> keeps growing.
>
> It is possible to replace StreamConverters with simple
> ```
> Sink
> .foreach[ByteString] {
> process.getOutputStream.write(bs.toArray)
> process.getOutputStream.flush()
> }
> ```
> and everything would work, but it's blocking and stuff.
>
> What may be the cause of this? I've tried to change settings of
> "default-blocking-io-dispatcher", but to no effect.
>
> --
> >>>>>>>>>> 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 https://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>
--
>>>>>>>>>> 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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
