Trait barter_data::MarketStream

pub trait MarketStream: Stream<Item = Result<Event<MarketData>, SocketError>> + Sized + Unpin {
    fn init<'life0, 'async_trait>(
        subscriptions: &'life0 [Subscription]
    ) -> Pin<Box<dyn Future<Output = Result<Self, SocketError>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
}

Stream supertrait for streams that yield MarketDatas. Provides an entry-point abstraction for an ExchangeWebSocket.

Required Methods

fn init<'life0, 'async_trait>(
    subscriptions: &'life0 [Subscription]
) -> Pin<Box<dyn Future<Output = Result<Self, SocketError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Initialises a new MarketData stream using the provided subscriptions.

Implementors

impl<Exchange> MarketStream for ExchangeWebSocket<Exchange> where
    Exchange: Subscriber + ExchangeTransformer + Send,
    <Exchange as Transformer<MarketData>>::Input: Identifiable,