Trait QueryStreamExt 

pub trait QueryStreamExt<T, C: Client> {
    // Required method
    fn subscribe<'life0, 'life1, 'async_trait>(
        &'life0 mut self,
        client: &'life1 C,
    ) -> Pin<Box<dyn Future<Output = Result<XmtpStream<<C as Client>::Stream, T>, ApiClientError<C::Error>>> + Send + 'async_trait>>
       where T: Default + Message + 'static,
             Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}

Required Methods

fn subscribe<'life0, 'life1, 'async_trait>( &'life0 mut self, client: &'life1 C, ) -> Pin<Box<dyn Future<Output = Result<XmtpStream<<C as Client>::Stream, T>, ApiClientError<C::Error>>> + Send + 'async_trait>>

where T: Default + Message + 'static, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Subscribe to the endpoint, indicating the type of stream item with R

Implementors

impl<T, C, E> QueryStreamExt<T, C> for E

where C: Client, E: Endpoint<Output = T>,