Trait barter_data::exchange::StreamSelector

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

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§

source

type Stream: MarketStream<Self, Kind>

Implementors§

source§

impl StreamSelector<OrderBooksL1> for Kraken

§

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

source§

impl StreamSelector<OrderBooksL2> for BinanceFuturesUsd

§

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

source§

impl StreamSelector<OrderBooksL2> for BinanceSpot

§

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

source§

impl StreamSelector<Liquidations> for BinanceFuturesUsd

§

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

source§

impl StreamSelector<PublicTrades> for Bitfinex

§

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

source§

impl StreamSelector<PublicTrades> for Bitmex

§

type Stream = ExchangeStream<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Bitmex, PublicTrades, BitmexMessage<BitmexTradeInner>>>

source§

impl StreamSelector<PublicTrades> for Coinbase

§

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

source§

impl StreamSelector<PublicTrades> for Kraken

§

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

source§

impl StreamSelector<PublicTrades> for Okx

§

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

source§

impl StreamSelector<PublicTrades> for GateioFuturesBtc

§

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

source§

impl StreamSelector<PublicTrades> for GateioFuturesUsd

§

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

source§

impl StreamSelector<PublicTrades> for GateioOptions

§

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

source§

impl StreamSelector<PublicTrades> for GateioPerpetualsBtc

§

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

source§

impl StreamSelector<PublicTrades> for GateioPerpetualsUsd

§

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

source§

impl StreamSelector<PublicTrades> for GateioSpot

§

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

source§

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>>

source§

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>>

source§

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

§

type Stream = ExchangeStream<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Bybit<Server>, PublicTrades, BybitMessage>>