RSocket

Streaming message protocol with Reactive Extension/Stream semantics