Struct phron_finality::network::substrate::NetworkEventStream

pub struct NetworkEventStream<B: Block, H: ExHashT> {
    stream: Pin<Box<dyn Stream<Item = Event> + Send>>,
    sync_stream: Pin<Box<dyn Stream<Item = SyncEvent> + Send>>,
    naming: ProtocolNaming,
    network: Arc<NetworkService<B, H>>,
}

Fields

stream: Pin<Box<dyn Stream<Item = Event> + Send>>

sync_stream: Pin<Box<dyn Stream<Item = SyncEvent> + Send>>

naming: ProtocolNaming

network: Arc<NetworkService<B, H>>

Trait Implementations

impl<B: Block, H: ExHashT> EventStream<PeerId> for NetworkEventStream<B, H>

fn next_event<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Option<Event<PeerId>>> + Send + 'async_trait>>

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

Retrieves next event from the stream or returns None if the stream is closed. This method’s implementation must be cancellation safe.