LiveDataClient

nautilus_live::data::client

Trait LiveDataClient 

Source 
pub trait LiveDataClient: DataClient {
    // Required methods
    fn connect<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn disconnect<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_message_channel(&self) -> UnboundedSender<DataEvent>;
    fn get_clock(&self) -> Ref<'_, dyn Clock>;
}

Required Methods§

Source

fn connect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Establishes a connection for live data.

§Errors

Returns an error if connection fails.

Source

fn disconnect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Disconnects the live data client.

§Errors

Returns an error if disconnection fails.

Source

fn get_message_channel(&self) -> UnboundedSender<DataEvent>

Source

fn get_clock(&self) -> Ref<'_, dyn Clock>

Implementors§