Trait barter_data::MarketStream

pub trait MarketStream: Stream<Item = Result<Event<MarketEvent>, 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 MarketEvents. Provides an entry-point abstraction for an ExchangeStream.

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 MarketStream using the provided subscriptions.

Implementors

impl<Exchange> MarketStream for ExchangeWsStream<Exchange>where
    Exchange: Subscriber + ExchangeTransformer + Send,