Non-fluent operators to interact with reactive-streams interfaces - View it on GitHub