Trait StreamSelector 

pub trait StreamSelector<Instrument, Kind>
where
    Self: Connector,
    Instrument: InstrumentData,
    Kind: SubscriptionKind,
{
    type SnapFetcher: SnapshotFetcher<Self, Kind>;
    type Stream: MarketStream<Self, Instrument, Kind>;
}

Defines the MarketStream kind associated with an exchange Subscription SubscriptionKind.

Notes

Must be implemented by an exchange Connector if it supports a specific SubscriptionKind.

Required Associated Types

type SnapFetcher: SnapshotFetcher<Self, Kind>

type Stream: MarketStream<Self, Instrument, Kind>

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<Instrument, Server> StreamSelector<Instrument, Candles> for Massive<Server>

where Instrument: InstrumentData, Server: MassiveServer + Debug + Send + Sync,

Per-second and per-minute aggregates. Any other interval is refused when subscribing.

type SnapFetcher = NoInitialSnapshots

type Stream = SharedStream<MassiveAttachment, MassiveTransformer<Massive<Server>, <Instrument as InstrumentData>::Key, Candles>>

impl<Instrument, Server> StreamSelector<Instrument, OrderBooksL1> for Alpaca<Server>

where Instrument: InstrumentData, Server: ExchangeServer + Debug + Send + Sync,

The same quotes as Quotes, as a top of book. See the OrderBookL1 conversion in quote for how a quote maps onto one.

type SnapFetcher = NoInitialSnapshots

type Stream = SharedStream<AlpacaAttachment, AlpacaQuoteTransformer<Alpaca<Server>, <Instrument as InstrumentData>::Key, OrderBooksL1>>

impl<Instrument, Server> StreamSelector<Instrument, OrderBooksL1> for Bybit<Server>

where Instrument: InstrumentData, Server: ExchangeServer + Debug + Send + Sync,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Bybit<Server>, <Instrument as InstrumentData>::Key, OrderBooksL1, BybitPayload<BybitOrderBookInner>>>

impl<Instrument, Server> StreamSelector<Instrument, OrderBooksL1> for Lse<Server>

where Instrument: InstrumentData, Server: LseQuoteServer + Debug + Send + Sync,

type SnapFetcher = NoInitialSnapshots

type Stream = SharedStream<LseAttachment, LseTransformer<Lse<Server>, <Instrument as InstrumentData>::Key, OrderBooksL1>>

impl<Instrument, Server> StreamSelector<Instrument, OrderBooksL1> for Massive<Server>

where Instrument: InstrumentData, Server: MassiveServer + Debug + Send + Sync,

The quotes channel, as a top of book. See OrderBooksL1’s MassiveKind implementation for how a quote maps onto one.

type SnapFetcher = NoInitialSnapshots

type Stream = SharedStream<MassiveAttachment, MassiveTransformer<Massive<Server>, <Instrument as InstrumentData>::Key, OrderBooksL1>>

impl<Instrument, Server> StreamSelector<Instrument, OrderBooksL2> for Bybit<Server>

where Instrument: InstrumentData, Server: ExchangeServer + Debug + Send + Sync,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, BybitOrderBooksL2Transformer<<Instrument as InstrumentData>::Key>>

impl<Instrument, Server> StreamSelector<Instrument, PublicTrades> for Alpaca<Server>

where Instrument: InstrumentData, Server: ExchangeServer + Debug + Send + Sync,

type SnapFetcher = NoInitialSnapshots

type Stream = SharedStream<AlpacaAttachment, AlpacaTradeTransformer<Alpaca<Server>, <Instrument as InstrumentData>::Key>>

impl<Instrument, Server> StreamSelector<Instrument, PublicTrades> for Bybit<Server>

where Instrument: InstrumentData, Server: ExchangeServer + Debug + Send + Sync,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Bybit<Server>, <Instrument as InstrumentData>::Key, PublicTrades, BybitPayload<Vec<BybitTradeInner>>>>

impl<Instrument, Server> StreamSelector<Instrument, PublicTrades> for Lse<Server>

where Instrument: InstrumentData, Server: LseServer + Debug + Send + Sync,

type SnapFetcher = NoInitialSnapshots

type Stream = SharedStream<LseAttachment, LseTransformer<Lse<Server>, <Instrument as InstrumentData>::Key, PublicTrades>>

impl<Instrument, Server> StreamSelector<Instrument, PublicTrades> for Massive<Server>

where Instrument: InstrumentData, Server: MassiveTradeServer + Debug + Send + Sync,

type SnapFetcher = NoInitialSnapshots

type Stream = SharedStream<MassiveAttachment, MassiveTransformer<Massive<Server>, <Instrument as InstrumentData>::Key, PublicTrades>>

impl<Instrument, Server> StreamSelector<Instrument, Quotes> for Alpaca<Server>

where Instrument: InstrumentData, Server: ExchangeServer + Debug + Send + Sync,

type SnapFetcher = NoInitialSnapshots

type Stream = SharedStream<AlpacaAttachment, AlpacaQuoteTransformer<Alpaca<Server>, <Instrument as InstrumentData>::Key>>

impl<Instrument, Server> StreamSelector<Instrument, Quotes> for Massive<Server>

where Instrument: InstrumentData, Server: MassiveServer + Debug + Send + Sync,

type SnapFetcher = NoInitialSnapshots

type Stream = SharedStream<MassiveAttachment, MassiveTransformer<Massive<Server>, <Instrument as InstrumentData>::Key, Quotes>>

impl<Instrument> StreamSelector<Instrument, Candles> for BinanceFuturesUsdMarket

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Binance<BinanceServerFuturesUsdMarket>, <Instrument as InstrumentData>::Key, Candles, BinanceContinuousKline>>

impl<Instrument> StreamSelector<Instrument, Candles> for BinanceSpot

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Binance<BinanceServerSpot>, <Instrument as InstrumentData>::Key, Candles, BinanceKline>>

impl<Instrument> StreamSelector<Instrument, Liquidations> for BinanceFuturesUsdMarket

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Binance<BinanceServerFuturesUsdMarket>, <Instrument as InstrumentData>::Key, Liquidations, BinanceLiquidation>>

impl<Instrument> StreamSelector<Instrument, OrderBooksL1> for BinanceFuturesUsd

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Binance<BinanceServerFuturesUsd>, <Instrument as InstrumentData>::Key, OrderBooksL1, BinanceOrderBookL1>>

impl<Instrument> StreamSelector<Instrument, OrderBooksL1> for BinanceSpot

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Binance<BinanceServerSpot>, <Instrument as InstrumentData>::Key, OrderBooksL1, BinanceOrderBookL1>>

impl<Instrument> StreamSelector<Instrument, OrderBooksL1> for Kraken

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Kraken, <Instrument as InstrumentData>::Key, OrderBooksL1, KrakenMessage<KrakenData<KrakenTicker>>>>

impl<Instrument> StreamSelector<Instrument, OrderBooksL2> for BinanceFuturesUsd

where Instrument: InstrumentData,

type SnapFetcher = BinanceFuturesUsdOrderBooksL2SnapshotFetcher

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, BinanceFuturesUsdOrderBooksL2Transformer<<Instrument as InstrumentData>::Key>>

impl<Instrument> StreamSelector<Instrument, OrderBooksL2> for BinanceSpot

where Instrument: InstrumentData,

type SnapFetcher = BinanceSpotOrderBooksL2SnapshotFetcher

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, BinanceSpotOrderBooksL2Transformer<<Instrument as InstrumentData>::Key>>

impl<Instrument> StreamSelector<Instrument, OrderBooksL2> for Hyperliquid

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Hyperliquid, <Instrument as InstrumentData>::Key, OrderBooksL2, HyperliquidL2Book>>

impl<Instrument> StreamSelector<Instrument, OrderBooksL2> for HyperliquidSpot

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<HyperliquidSpot, <Instrument as InstrumentData>::Key, OrderBooksL2, HyperliquidL2Book>>

impl<Instrument> StreamSelector<Instrument, PublicTrades> for BinanceFuturesUsd

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Binance<BinanceServerFuturesUsd>, <Instrument as InstrumentData>::Key, PublicTrades, BinanceTrade>>

impl<Instrument> StreamSelector<Instrument, PublicTrades> for BinanceSpot

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Binance<BinanceServerSpot>, <Instrument as InstrumentData>::Key, PublicTrades, BinanceTrade>>

impl<Instrument> StreamSelector<Instrument, PublicTrades> for Bitfinex

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Bitfinex, <Instrument as InstrumentData>::Key, PublicTrades, BitfinexMessage>>

impl<Instrument> StreamSelector<Instrument, PublicTrades> for Bitmex

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Bitmex, <Instrument as InstrumentData>::Key, PublicTrades, BitmexMessage<BitmexTradeInner>>>

impl<Instrument> StreamSelector<Instrument, PublicTrades> for Coinbase

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Coinbase, <Instrument as InstrumentData>::Key, PublicTrades, CoinbaseTrade>>

impl<Instrument> StreamSelector<Instrument, PublicTrades> for GateioFuturesBtc

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Gateio<GateioServerFuturesBtc>, <Instrument as InstrumentData>::Key, PublicTrades, GateioMessage<Vec<GateioFuturesTradeInner>>>>

impl<Instrument> StreamSelector<Instrument, PublicTrades> for GateioFuturesUsd

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Gateio<GateioServerFuturesUsd>, <Instrument as InstrumentData>::Key, PublicTrades, GateioMessage<Vec<GateioFuturesTradeInner>>>>

impl<Instrument> StreamSelector<Instrument, PublicTrades> for GateioOptions

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Gateio<GateioServerOptions>, <Instrument as InstrumentData>::Key, PublicTrades, GateioMessage<Vec<GateioFuturesTradeInner>>>>

impl<Instrument> StreamSelector<Instrument, PublicTrades> for GateioPerpetualsBtc

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Gateio<GateioServerPerpetualsBtc>, <Instrument as InstrumentData>::Key, PublicTrades, GateioMessage<Vec<GateioFuturesTradeInner>>>>

impl<Instrument> StreamSelector<Instrument, PublicTrades> for GateioPerpetualsUsd

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Gateio<GateioServerPerpetualsUsd>, <Instrument as InstrumentData>::Key, PublicTrades, GateioMessage<Vec<GateioFuturesTradeInner>>>>

impl<Instrument> StreamSelector<Instrument, PublicTrades> for GateioSpot

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Gateio<GateioServerSpot>, <Instrument as InstrumentData>::Key, PublicTrades, GateioMessage<GateioSpotTradeInner>>>

impl<Instrument> StreamSelector<Instrument, PublicTrades> for Hyperliquid

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Hyperliquid, <Instrument as InstrumentData>::Key, PublicTrades, HyperliquidTrade>>

impl<Instrument> StreamSelector<Instrument, PublicTrades> for HyperliquidSpot

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<HyperliquidSpot, <Instrument as InstrumentData>::Key, PublicTrades, HyperliquidTrade>>

impl<Instrument> StreamSelector<Instrument, PublicTrades> for Kraken

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Kraken, <Instrument as InstrumentData>::Key, PublicTrades, KrakenMessage<KrakenData<KrakenTrade>>>>

impl<Instrument> StreamSelector<Instrument, PublicTrades> for Okx

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketSerdeParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Okx, <Instrument as InstrumentData>::Key, PublicTrades, OkxMessage<OkxTrade>>>