Advanced, backpressure-aware reactive library, based on the ported Reactive-Streams specification (ReactiveStreamsCS), including support for RxJava-equivalent Single and Completable classes.
https://www.nuget.org/packages/RxAdvancedFlow/
PM> Install-Package RxAdvancedFlow