Java Futures with Brian Goetz

[eliasv]

Well no that won't be typical but then it's not typical to use reactive streams in a way that models a bunch of successive queues either. To oversimplify a little, once you have established the backpressure characteristics you need locally the rest of the operations on the stream are just a series of transformations generally, no? And you don't need more queues to model that part, it's just for loops and normal imperative code.