Struct barter_data::transformer::book::MultiBookTransformer

pub struct MultiBookTransformer<Exchange, Kind, Updater> {
    pub book_map: Map<InstrumentOrderBook<Updater>>,
    /* private fields */
}

Standard generic ExchangeTransformer to translate exchange specific OrderBook types into normalised Barter OrderBook types. Requires an exchange specific OrderBookUpdater implementation.

Fields

book_map: Map<InstrumentOrderBook<Updater>>

Trait Implementations

impl<Exchange: Clone, Kind: Clone, Updater: Clone> Clone for MultiBookTransformer<Exchange, Kind, Updater>

fn clone(&self) -> MultiBookTransformer<Exchange, Kind, Updater>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Exchange: Debug, Kind: Debug, Updater: Debug> Debug for MultiBookTransformer<Exchange, Kind, Updater>

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

Formats the value using the given formatter.

impl<'de, Exchange, Kind, Updater> Deserialize<'de> for MultiBookTransformer<Exchange, Kind, Updater>where
    Updater: Deserialize<'de>,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
    __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<Exchange, Kind, Updater> ExchangeTransformer<Exchange, Kind> for MultiBookTransformer<Exchange, Kind, Updater>where
    Exchange: Connector + Send,
    Kind: SubKind<Event = OrderBook> + Send,
    Updater: OrderBookUpdater<OrderBook = Kind::Event> + Send,
    Updater::Update: Identifier<Option<SubscriptionId>> + for<'de> Deserialize<'de>,

fn new<'async_trait>(
    ws_sink_tx: UnboundedSender<WsMessage>,
    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, Updater: PartialEq> PartialEq<MultiBookTransformer<Exchange, Kind, Updater>> for MultiBookTransformer<Exchange, Kind, Updater>

fn eq(&self, other: &MultiBookTransformer<Exchange, Kind, Updater>) -> 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, Updater> Serialize for MultiBookTransformer<Exchange, Kind, Updater>where
    Updater: Serialize,

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, Updater> Transformer for MultiBookTransformer<Exchange, Kind, Updater>where
    Exchange: Connector,
    Kind: SubKind<Event = OrderBook>,
    Updater: OrderBookUpdater<OrderBook = Kind::Event>,
    Updater::Update: Identifier<Option<SubscriptionId>> + for<'de> Deserialize<'de>,

type Error = DataError

type Input = <Updater as OrderBookUpdater>::Update

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

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

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

impl<Exchange, Kind, Updater> StructuralPartialEq for MultiBookTransformer<Exchange, Kind, Updater>