C# port of the backpressure-aware, Reactive-Streams compliant RxJava 2.0 with fluent API - View it on GitHub