Struct barter_data::transformer::book::MultiBookTransformer

pub struct MultiBookTransformer<Exchange, InstrumentId, Kind, Updater> {
    pub book_map: Map<InstrumentOrderBook<InstrumentId, 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<InstrumentId, Updater>>

Trait Implementations

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

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

Returns a copy of the value.

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

Performs copy-assignment from source.

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

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

Formats the value using the given formatter.

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

where InstrumentId: Deserialize<'de>, 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, Instrument, Kind> for MultiBookTransformer<Exchange, Instrument, Kind, Updater>

where Exchange: Connector + Send, Kind: SubscriptionKind<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, InstrumentId: PartialEq, Kind: PartialEq, Updater: PartialEq> PartialEq for MultiBookTransformer<Exchange, InstrumentId, Kind, Updater>

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

where InstrumentId: Serialize, 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, InstrumentId, Kind, Updater> Transformer for MultiBookTransformer<Exchange, InstrumentId, Kind, Updater>

where Exchange: Connector, InstrumentId: Clone, Kind: SubscriptionKind<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<InstrumentId, <Kind as SubscriptionKind>::Event>

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

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

impl<Exchange: Eq, InstrumentId: Eq, Kind: Eq, Updater: Eq> Eq for MultiBookTransformer<Exchange, InstrumentId, Kind, Updater>

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