Module consumer

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.