There was an initiative not long ago called Reactive Streams which established some common interfaces to build things like this. Back pressure was one of the m

There was an initiative not long ago called Reactive Streams which established some common interfaces to build things like this. Back pressure was one of the main concerns. Some implementations are listed here: http://www.reactive-streams.org/announce-1.0.0 http://www.reactive-streams.org/announce-1.0.0