Reactor streaming to be more in line with upcoming reactive-stream.org resp. akka-streams
Add an overall inactivity timeout just to be sure