Trait EventsSource

pub trait EventsSource<Types>
where
    Types: NodeType,
{
    type EventStream: Stream<Item = Arc<Event<Types>>> + Unpin + Send + 'static;
    type LegacyEventStream: Stream<Item = Arc<LegacyEvent<Types>>> + Unpin + Send + 'static;

    // Required methods
    fn get_event_stream<'life0, 'async_trait>(
        &'life0 self,
        filter: Option<EventFilterSet<Types>>,
    ) -> Pin<Box<dyn Future<Output = Self::EventStream> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_legacy_event_stream<'life0, 'async_trait>(
        &'life0 self,
        filter: Option<EventFilterSet<Types>>,
    ) -> Pin<Box<dyn Future<Output = Self::LegacyEventStream> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_startup_info<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = StartupInfo<Types>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Required Associated Types

type EventStream: Stream<Item = Arc<Event<Types>>> + Unpin + Send + 'static

type LegacyEventStream: Stream<Item = Arc<LegacyEvent<Types>>> + Unpin + Send + 'static

Required Methods

fn get_event_stream<'life0, 'async_trait>( &'life0 self, filter: Option<EventFilterSet<Types>>, ) -> Pin<Box<dyn Future<Output = Self::EventStream> + Send + 'async_trait>>

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

fn get_legacy_event_stream<'life0, 'async_trait>( &'life0 self, filter: Option<EventFilterSet<Types>>, ) -> Pin<Box<dyn Future<Output = Self::LegacyEventStream> + Send + 'async_trait>>

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

fn get_startup_info<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = StartupInfo<Types>> + Send + 'async_trait>>

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

Implementors

impl<Types: NodeType> EventsSource<Types> for EventsStreamer<Types>

type EventStream = Pin<Box<dyn Stream<Item = Arc<Event<Types>>> + Send>>

type LegacyEventStream = Pin<Box<dyn Stream<Item = Arc<LegacyEvent<Types>>> + Send>>