Module pump 

Event pump: frames -> core -> per-subscription buffers -> the client’s Sender.

Never blocks on a slow consumer: events wait in the subscription’s buffer, and the pump hands them to out only when it has room (reserve). A Lossless buffer that fills up is terminal: one Event::Overflow, on_overflow (connector goes Degraded), later events of that subscription are dropped until reconcile clears the state.

Structs

PumpIo

The channels and handles one run_pump task works with.

Functions

run_pump

Runs until cancelled, the frame channel closes, or the consumer drops the receiver.

Type Aliases

SharedBackpressure

The per-subscription buffers, shared between the pump and the connector (which registers and unregisters subscriptions in it).