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", so this trait is not object safe.

Implementors

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

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

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

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

where Instrument: InstrumentData,

type SnapFetcher = BinanceFuturesUsdOrderBooksL2SnapshotFetcher

type Stream = ExchangeStream<WebSocketParser, 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<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, BinanceSpotOrderBooksL2Transformer<<Instrument as InstrumentData>::Key>>

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

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

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

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

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketParser, 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<WebSocketParser, 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<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Coinbase, <Instrument as InstrumentData>::Key, PublicTrades, CoinbaseTrade>>

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

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

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

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

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

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

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

where Instrument: InstrumentData,

type SnapFetcher = NoInitialSnapshots

type Stream = ExchangeStream<WebSocketParser, 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<WebSocketParser, 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<WebSocketParser, 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<WebSocketParser, 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<WebSocketParser, 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<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Gateio<GateioServerSpot>, <Instrument as InstrumentData>::Key, PublicTrades, GateioMessage<GateioSpotTradeInner>>>

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

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

type SnapFetcher = NoInitialSnapshots

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

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

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

type SnapFetcher = NoInitialSnapshots

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

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

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

type SnapFetcher = NoInitialSnapshots

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

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

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

type SnapFetcher = NoInitialSnapshots

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

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

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

type SnapFetcher = NoInitialSnapshots

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