Trait barter_data::exchange::StreamSelector

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

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§

source

type Stream: MarketStream<Self, Instrument, Kind>

Object Safety§

This trait is not object safe.

Implementors§

source§

impl StreamSelector<Instrument, OrderBooksL2> for BinanceFuturesUsd

§

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

source§

impl StreamSelector<Instrument, OrderBooksL2> for BinanceSpot

§

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

source§

impl<Instrument> StreamSelector<Instrument, OrderBooksL1> for Kraken
where Instrument: InstrumentData,

§

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

source§

impl<Instrument> StreamSelector<Instrument, Liquidations> for BinanceFuturesUsd
where Instrument: InstrumentData,

§

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

source§

impl<Instrument> StreamSelector<Instrument, PublicTrades> for Bitfinex
where Instrument: InstrumentData,

§

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

source§

impl<Instrument> StreamSelector<Instrument, PublicTrades> for Bitmex
where Instrument: InstrumentData,

§

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

source§

impl<Instrument> StreamSelector<Instrument, PublicTrades> for Coinbase
where Instrument: InstrumentData,

§

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

source§

impl<Instrument> StreamSelector<Instrument, PublicTrades> for Kraken
where Instrument: InstrumentData,

§

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

source§

impl<Instrument> StreamSelector<Instrument, PublicTrades> for Okx
where Instrument: InstrumentData,

§

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

source§

impl<Instrument> StreamSelector<Instrument, PublicTrades> for GateioFuturesBtc
where Instrument: InstrumentData,

§

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

source§

impl<Instrument> StreamSelector<Instrument, PublicTrades> for GateioFuturesUsd
where Instrument: InstrumentData,

§

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

source§

impl<Instrument> StreamSelector<Instrument, PublicTrades> for GateioOptions
where Instrument: InstrumentData,

§

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

source§

impl<Instrument> StreamSelector<Instrument, PublicTrades> for GateioPerpetualsBtc
where Instrument: InstrumentData,

§

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

source§

impl<Instrument> StreamSelector<Instrument, PublicTrades> for GateioPerpetualsUsd
where Instrument: InstrumentData,

§

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

source§

impl<Instrument> StreamSelector<Instrument, PublicTrades> for GateioSpot
where Instrument: InstrumentData,

§

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

source§

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

§

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

source§

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

§

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

source§

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

§

type Stream = ExchangeStream<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Bybit<Server>, <Instrument as InstrumentData>::Id, PublicTrades, BybitMessage>>