Struct StatelessTransformer 

pub struct StatelessTransformer<Exchange, InstrumentKey, Kind, Input> { /* private fields */ }

Standard generic stateless ExchangeTransformer to translate exchange specific types into normalised Barter types. Often used with PublicTrades or OrderBooksL1 streams.

Trait Implementations

impl<Exchange: Clone, InstrumentKey: Clone, Kind: Clone, Input: Clone> Clone for StatelessTransformer<Exchange, InstrumentKey, Kind, Input>

fn clone(&self) -> StatelessTransformer<Exchange, InstrumentKey, Kind, Input>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Exchange: Debug, InstrumentKey: Debug, Kind: Debug, Input: Debug> Debug for StatelessTransformer<Exchange, InstrumentKey, Kind, Input>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<Exchange, InstrumentKey, Kind, Input> ExchangeTransformer<Exchange, InstrumentKey, Kind> for StatelessTransformer<Exchange, InstrumentKey, Kind, Input>

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

fn init<'life0, 'async_trait>( instrument_map: Map<InstrumentKey>, _: &'life0 [MarketEvent<InstrumentKey, Kind::Event>], __arg2: UnboundedSender<WsMessage>, ) -> Pin<Box<dyn Future<Output = Result<Self, DataError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

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

impl<Exchange: PartialEq, InstrumentKey: PartialEq, Kind: PartialEq, Input: PartialEq> PartialEq for StatelessTransformer<Exchange, InstrumentKey, Kind, Input>

fn eq( &self, other: &StatelessTransformer<Exchange, InstrumentKey, Kind, Input>, ) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<Exchange, InstrumentKey, Kind, Input> Transformer for StatelessTransformer<Exchange, InstrumentKey, Kind, Input>

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

type Error = DataError

type Input = Input

type Output = MarketEvent<InstrumentKey, <Kind as SubscriptionKind>::Event>

type OutputIter = Vec<Result<<StatelessTransformer<Exchange, InstrumentKey, Kind, Input> as Transformer>::Output, <StatelessTransformer<Exchange, InstrumentKey, Kind, Input> as Transformer>::Error>>

fn transform(&mut self, input: Self::Input) -> Self::OutputIter

impl<Exchange: Eq, InstrumentKey: Eq, Kind: Eq, Input: Eq> Eq for StatelessTransformer<Exchange, InstrumentKey, Kind, Input>

impl<Exchange, InstrumentKey, Kind, Input> StructuralPartialEq for StatelessTransformer<Exchange, InstrumentKey, Kind, Input>