Expand description
High-level API types used for building MarketStreams from collections
of Barter Subscriptions.
Modules§
- blocking
- Bridges a blocking source — a Parquet artifact, a compressed archive — into a bounded,
back-pressured
Stream, off the async runtime’s workers. - builder
- Defines the
StreamBuilderandMultiStreamBuilderAPIs for ergonomically initialisingMarketStreamStreams. - consumer
- Central consumer loop functionality used by the
StreamBuilderto drive a re-connectingMarketStream. - merge
- Lazily merge N time-sorted market streams into one, for replaying multi-instrument historical data as a single time-ordered feed.
- reconnect
- Defines a
ReconnectingStreamand associated logic for generating an auto reconnectingStream.
Structs§
- Streams
- Ergonomic collection of exchange market event receivers.