This is your work, valued

RSocket

Elite
@rsocket

Streaming message protocol with Reactive Extension/Stream semantics

rsocket.io