Reactive Streams adapter for Apache Pulsar Java Client - View it on GitHub