Module consumer

Source
Expand description

Central consumer loop functionality used by the StreamBuilder to drive a re-connecting MarketStream.

Structs§

StreamKey

Constants§

STREAM_RECONNECTION_POLICY
Default ReconnectionBackoffPolicy for a reconnecting MarketStream.

Functions§

init_market_stream
Initialises a reconnecting MarketStream using a collection of Subscriptions.

Type Aliases§

MarketStreamEvent
Convenient type alias for a MarketEvent consumed via a reconnecting MarketStream.
MarketStreamResult
Convenient type alias for a MarketEvent Result consumed via a reconnecting MarketStream.