Subscription implementation draws inspiration from the ReactiveX and reactive streams libraries and provides easy interoperability with them. For more information about these classes please see the quick tour primer.
The Reactive streams initiative provides interfaces that allow reactive stream based systems to interact. The API is similar to the MongoDB
Observable API but without the composability of the MongoDB implementation.
Converting from an
Observable to a
Publisher is a simple process and can be done in a few short lines of code. An implicit based conversion can be found in the examples folder.