Module memory 

In-memory buffering with backpressure for Kinetic.

Structs

BufferReceiver

A receiver handle from a memory buffer.

BufferSender

A sender handle to a memory buffer.

Enums

WhenFull

Policy for what to do when a buffer is full.

Functions

channel

Creates a new memory buffer with the given capacity (in batches).