Re: [akka-user] How would you "connect" many independent graphs maintaining backpressure between them?

Hi Jack, Queue.offer returns a Future, you can use that in a mapAsync in the stream you want to transitively throttle. As you noted, this can fail though, if the queue is full. What I would do is probably just use Future composition (recoverWith in this case) to implement a retry logic (and

Re: [akka-user] How would you "connect" many independent graphs maintaining backpressure between them?

Ah, sorry, I should've looked more carefully. AFAICT you'll need to figure out what throttling means for a fan-in operation. (Because now you're adding an unbounded queue (the CLQ)) On Sun, Jul 10, 2016 at 4:31 PM, Jack Daniels wrote: > Hi! I use it in the example

Re: [akka-user] How would you "connect" many independent graphs maintaining backpressure between them?

Hi! I use it in the example provided above. The problem is how to throttle other graphs that are not connected to throttled graph. On Friday, July 8, 2016 at 2:24:04 PM UTC+3, √ wrote: > > Considered Flow.throttle? > > On Fri, Jul 8, 2016 at 11:23 AM, Jack Daniels >

Re: [akka-user] How would you "connect" many independent graphs maintaining backpressure between them?

Considered Flow.throttle? On Fri, Jul 8, 2016 at 11:23 AM, Jack Daniels wrote: > up vote > down votefavorite > > > Hey guys! I continue learning

[akka-user] How would you "connect" many independent graphs maintaining backpressure between them?

up vote down votefavorite Hey guys! I continue learning akka-streams and have new question . *Variables:* - Single http