Trait XmtpQuery 

pub trait XmtpQuery: MaybeSend + MaybeSync {
    type Error: RetryableError + 'static;

    // Required method
    fn query_at<'life0, 'async_trait>(
        &'life0 self,
        topic: Topic,
        at: Option<GlobalCursor>,
    ) -> Pin<Box<dyn Future<Output = Result<XmtpEnvelope, Self::Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

matching the cursor criteria given.

Required Associated Types

type Error: RetryableError + 'static

Required Methods

fn query_at<'life0, 'async_trait>( &'life0 self, topic: Topic, at: Option<GlobalCursor>, ) -> Pin<Box<dyn Future<Output = Result<XmtpEnvelope, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Query every Topic at GlobalCursor

Implementations on Foreign Types

impl<T> XmtpQuery for Box<T>

where T: XmtpQuery + ?Sized,

fn query_at<'life0, 'async_trait>( &'life0 self, topic: Topic, at: Option<GlobalCursor>, ) -> Pin<Box<dyn Future<Output = Result<XmtpEnvelope, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Query every Topic at GlobalCursor

type Error = <T as XmtpQuery>::Error

impl<T> XmtpQuery for Arc<T>

where T: XmtpQuery + ?Sized,

fn query_at<'life0, 'async_trait>( &'life0 self, topic: Topic, at: Option<GlobalCursor>, ) -> Pin<Box<dyn Future<Output = Result<XmtpEnvelope, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Query every Topic at GlobalCursor

type Error = <T as XmtpQuery>::Error

Implementors

impl<C, Store, E> XmtpQuery for D14nClient<C, Store>

where C: Client<Error = E>, ApiClientError<E>: From<ApiClientError<<C as Client>::Error>>, E: RetryableError + 'static, Store: CursorStore,

type Error = ApiClientError<E>

impl<C, Store, E> XmtpQuery for V3Client<C, Store>

where C: Client<Error = E>, E: RetryableError + 'static, ApiClientError<E>: From<ApiClientError<<C as Client>::Error>>, Store: CursorStore,

type Error = ApiClientError<E>

impl<C: XmtpQuery> XmtpQuery for BoxedStreamsClient<C>

type Error = <C as XmtpQuery>::Error

impl<C: XmtpQuery> XmtpQuery for TrackedStatsClient<C>

type Error = <C as XmtpQuery>::Error