Trait ExchangeTransformer 

pub trait ExchangeTransformer<Exchange, InstrumentKey, Kind>
where
    Self: Transformer<Output = MarketEvent<InstrumentKey, Kind::Event>, Error = DataError> + Sized,
    Kind: SubscriptionKind,
{
    // Required method
    fn init(
        instrument_map: Map<InstrumentKey>,
        initial_snapshots: &[MarketEvent<InstrumentKey, Kind::Event>],
        ws_sink_tx: UnboundedSender<WsMessage>,
    ) -> impl Future<Output = Result<Self, DataError>> + Send
       where InstrumentKey: Sync,
             Kind::Event: Sync;
}

Defines how to construct a Transformer used by MarketStreams to translate exchange specific types to normalised Barter types.

Required Methods

fn init( instrument_map: Map<InstrumentKey>, initial_snapshots: &[MarketEvent<InstrumentKey, Kind::Event>], ws_sink_tx: UnboundedSender<WsMessage>, ) -> impl Future<Output = Result<Self, DataError>> + Send

where InstrumentKey: Sync, Kind::Event: Sync,

Initialise a new Self, also fetching any market data snapshots required for the associated Exchange and SubscriptionKind market stream to function.

The mpsc::UnboundedSender can be used by Self to send messages back to the exchange.

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<Exchange, InstrumentKey, Kind, Input> ExchangeTransformer<Exchange, InstrumentKey, Kind> for StatelessTransformer<Exchange, InstrumentKey, Kind, Input>

where Exchange: Connector + Send, InstrumentKey: Clone + Send + Sync, Kind: SubscriptionKind + Send, Kind::Event: Sync, Input: Identifier<Option<SubscriptionId>> + for<'de> Deserialize<'de>, MarketIter<InstrumentKey, Kind::Event>: From<(ExchangeId, InstrumentKey, Input)>,

impl<InstrumentKey> ExchangeTransformer<Binance<BinanceServerFuturesUsd>, InstrumentKey, OrderBooksL2> for BinanceFuturesUsdOrderBooksL2Transformer<InstrumentKey>

where InstrumentKey: Clone + PartialEq + Send + Sync,

impl<InstrumentKey> ExchangeTransformer<Binance<BinanceServerSpot>, InstrumentKey, OrderBooksL2> for BinanceSpotOrderBooksL2Transformer<InstrumentKey>

where InstrumentKey: Clone + PartialEq + Send + Sync,

impl<InstrumentKey, Server> ExchangeTransformer<Bybit<Server>, InstrumentKey, OrderBooksL2> for BybitOrderBooksL2Transformer<InstrumentKey>

where InstrumentKey: Clone + PartialEq + Send + Sync, Server: Send,