Async stream processing in CPP inspired by www.reactive-streams.org