Struct barter_data::transformer::stateless::StatelessTransformer

pub struct StatelessTransformer<Exchange, 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, Kind: Clone, Input: Clone> Clone for StatelessTransformer<Exchange, Kind, Input>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

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

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

Formats the value using the given formatter.

impl<Exchange, Kind, Input> ExchangeTransformer<Exchange, Kind> for StatelessTransformer<Exchange, Kind, Input>where
    Exchange: Connector + Send,
    Kind: SubKind + Send,
    Input: Identifier<Option<SubscriptionId>> + for<'de> Deserialize<'de>,
    MarketIter<Kind::Event>: From<(ExchangeId, Instrument, Input)>,

fn new<'async_trait>(
    __arg0: UnboundedSender<WsMessage>,
    instrument_map: Map<Instrument>
) -> Pin<Box<dyn Future<Output = Result<Self, DataError>> + Send + 'async_trait>>where
    Self: 'async_trait,

Construct a new Self.

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

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

This method tests for self and other values to be equal, and is used by ==.

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

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

impl<Exchange, Kind, Input> Serialize for StatelessTransformer<Exchange, Kind, Input>

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where
    __S: Serializer,

Serialize this value into the given Serde serializer.

impl<Exchange, Kind, Input> Transformer for StatelessTransformer<Exchange, Kind, Input>where
    Exchange: Connector,
    Kind: SubKind,
    Input: Identifier<Option<SubscriptionId>> + for<'de> Deserialize<'de>,
    MarketIter<Kind::Event>: From<(ExchangeId, Instrument, Input)>,

type Error = DataError

type Input = Input

type Output = MarketEvent<<Kind as SubKind>::Event>

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

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

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

impl<Exchange, Kind, Input> StructuralEq for StatelessTransformer<Exchange, Kind, Input>

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