Trait ExExNotificationsStream

pub trait ExExNotificationsStream<N: NodePrimitives = EthPrimitives>: Stream<Item = Result<ExExNotification<N>>> + Unpin {
    // Required methods
    fn set_without_head(&mut self);
    fn set_with_head(&mut self, exex_head: ExExHead);
    fn without_head(self) -> Self
       where Self: Sized;
    fn with_head(self, exex_head: ExExHead) -> Self
       where Self: Sized;
}

A trait, that represents a stream of ExExNotifications. The stream will emit notifications for all blocks. If the stream is configured with a head via ExExNotifications::set_with_head or ExExNotifications::with_head, it will run backfill jobs to catch up to the node head.

Required Methods

fn set_without_head(&mut self)

Sets ExExNotificationsStream to a stream of ExExNotifications without a head.

It’s a no-op if the stream has already been configured without a head.

See the documentation of ExExNotificationsWithoutHead for more details.

fn set_with_head(&mut self, exex_head: ExExHead)

Sets ExExNotificationsStream to a stream of ExExNotifications with the provided head.

It’s a no-op if the stream has already been configured with a head.

See the documentation of ExExNotificationsWithHead for more details.

fn without_head(self) -> Self

where Self: Sized,

Returns a new ExExNotificationsStream without a head.

See the documentation of ExExNotificationsWithoutHead for more details.

fn with_head(self, exex_head: ExExHead) -> Self

where Self: Sized,

Returns a new ExExNotificationsStream with the provided head.

See the documentation of ExExNotificationsWithHead for more details.

Implementors

impl<P, E> ExExNotificationsStream<<E as BlockExecutorProvider>::Primitives> for ExExNotifications<P, E>

where P: BlockReader + HeaderProvider + StateProviderFactory + Clone + Unpin + 'static, E: BlockExecutorProvider<Primitives: NodePrimitives<Block = P::Block>> + Clone + Unpin + 'static,