Trait barter_data::exchange::StreamSelector

pub trait StreamSelector<Kind>where
    Self: Connector,
    Kind: SubKind,{
    type Stream: MarketStream<Self, Kind>;
}

Defines the MarketStream kind associated with an exchange Subscription SubKind.

Notes

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

Required Associated Types

type Stream: MarketStream<Self, Kind>

Implementors

impl StreamSelector<OrderBooksL1> for Kraken

type Stream = ExchangeStream<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Kraken, OrderBooksL1, KrakenMessage<KrakenOrderBookL1Inner>>>

impl StreamSelector<OrderBooksL2> for BinanceFuturesUsd

type Stream = ExchangeStream<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, MultiBookTransformer<Binance<BinanceServerFuturesUsd>, OrderBooksL2, BinanceFuturesBookUpdater>>

impl StreamSelector<OrderBooksL2> for BinanceSpot

type Stream = ExchangeStream<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, MultiBookTransformer<Binance<BinanceServerSpot>, OrderBooksL2, BinanceSpotBookUpdater>>

impl StreamSelector<Liquidations> for BinanceFuturesUsd

type Stream = ExchangeStream<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Binance<BinanceServerFuturesUsd>, Liquidations, BinanceLiquidation>>

impl StreamSelector<PublicTrades> for Bitfinex

type Stream = ExchangeStream<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Bitfinex, PublicTrades, BitfinexMessage>>

impl StreamSelector<PublicTrades> for Coinbase

type Stream = ExchangeStream<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Coinbase, PublicTrades, CoinbaseTrade>>

impl StreamSelector<PublicTrades> for Kraken

type Stream = ExchangeStream<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Kraken, PublicTrades, KrakenMessage<KrakenTradesInner>>>

impl StreamSelector<PublicTrades> for Okx

type Stream = ExchangeStream<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Okx, PublicTrades, OkxMessage<OkxTrade>>>

impl StreamSelector<PublicTrades> for GateioFuturesBtc

type Stream = ExchangeStream<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Gateio<GateioServerFuturesBtc>, PublicTrades, GateioMessage<Vec<GateioFuturesTradeInner, Global>>>>

impl StreamSelector<PublicTrades> for GateioFuturesUsd

type Stream = ExchangeStream<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Gateio<GateioServerFuturesUsd>, PublicTrades, GateioMessage<Vec<GateioFuturesTradeInner, Global>>>>

impl StreamSelector<PublicTrades> for GateioSpot

type Stream = ExchangeStream<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Gateio<GateioServerSpot>, PublicTrades, GateioMessage<GateioSpotTradeInner>>>

impl<Server> StreamSelector<OrderBooksL1> for Binance<Server>where
    Server: ExchangeServer + Debug + Send + Sync,

type Stream = ExchangeStream<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Binance<Server>, OrderBooksL1, BinanceOrderBookL1>>

impl<Server> StreamSelector<PublicTrades> for Binance<Server>where
    Server: ExchangeServer + Debug + Send + Sync,

type Stream = ExchangeStream<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Binance<Server>, PublicTrades, BinanceTrade>>