Re: [akka-user] [akka-stream] how to control the throughput of a certain flow

Might want to look into mapAsync and mapAsyncUnordered for the linear parts of your slow graph. You can specify the desired parallelism as part of those calls. I was about to write that in general there isn't a "make fast" button for arbitrary graphs. However, that may not be strictly true.

Re: [akka-user] [akka-stream] how to control the throughput of a certain flow

Just read it, to be more specific, if I want to enlarge the capacity of a certain flow, I can do like this: http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0-M1/scala/stream-cookbook.html#cookbook-balance-scala i.e.: using Balance/Merge to get a composite flow from original flow.

Re: [akka-user] [akka-stream] how to control the throughput of a certain flow

What you need is in progress: https://github.com/akka/akka/pull/18887 -Endre On Wed, Nov 18, 2015 at 11:17 AM, Leon Ma wrote: > Just read it, to be more specific, if I want to enlarge the capacity of a > certain flow, I can do like this: > > >

Re: [akka-user] [akka-stream] how to control the throughput of a certain flow

The Pipelining and Parallelism chapter in the documentation is a good read. Regards, Patrik On Wed, Nov 11, 2015 at 4:13 AM, Leon Ma wrote: > Hi, > > Assuming I have below flows:

[akka-user] [akka-stream] how to control the throughput of a certain flow

Hi, Assuming I have below flows: Source(..).via(flow1).via(flow2).via(flow3).to(...) questions: 1. how many actors will be created when run this flow? 1 actor for 1 flow? 2. if I found that flow2 is slower than others (bottle neck), Can I enlarge capacity for it? for example, use some router