Reactive Remote Procedure/Publisher Call/Consumption library based on Reactive-Streams - View it on GitHub