Module stream 

Concrete stream newtypes for the multiplexed WS surface.

These replace the Pin<Box<dyn Stream<Item = ...>>> aliases used in the 0.1 trait. The receiver channel is an implementation detail; the public surface is Stream<Item = T> and a direct recv().await shortcut for hot-path callers that want to avoid Stream combinators entirely.

Structs

SessionStream

Connection-level events. Separate from UpdateStream so one reconnect is one event regardless of how many markets are subscribed.

UpdateStream

Multiplexed per-market update stream. There is exactly one UpdateStream per dispatcher; calling OrderBookWebSocket::updates() twice returns None the second time.

WsDispatcher

Producer handle held by exchange WS implementations. Owns the sender halves of both channels so the implementation can emit updates and session events directly.

WsDispatcherConfig

Configuration for the dispatcher’s bounded channels.