Module barter_data::streams::consumer

source ·
Expand description

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

Constants

STARTING_RECONNECT_BACKOFF_MS
Initial duration that the consume function should wait after disconnecting before attempting to re-initialise a MarketStream. This duration will increase exponentially as a result of repeated disconnections with re-initialisation failures.

Functions

consume
Central MarketEvent<T> consumer loop.