Closeable interface implements Disposable

Closeable implements Disposable now as removes the close method that returns a Mono.

cleanup

RSocketClient cleans up connections properly now, and disposes subscriptions.

Recycle payloads refcnt

Increments refcnt when retrieving recycled payload

Recycle payloads

Recycles the ByteBufPayload because it is RefCnt

Zero Copy

RSocket was copying the metadata and data fields when return them to the call. This lets you use a FrameDecoder so you can get the ByteBuf and return zero copies. In the TCP ping/pong test increases performances ~38% and lowers tail latency ~100 ms.

Handle Errors properly

When a server receives an Error frame it no longer closes the connection.

SwitchTransform IllegalStateException

Fixes SwitchTransform so that it doesn't throw an IllegalStateException

Fixes channel streaming

Address issues with streaming with channels

Fixed onClose

Netty duplex connections no longer solely rely on events from Netty to close - ensures that onClose events are propogated

Frame ordering

Emits frames in correct order when multiple threads on next-ing to send processor.