Trait CanonStateSubscriptions

pub trait CanonStateSubscriptions: Send + Sync {
    // Required method
    fn subscribe_to_canonical_state(&self) -> Receiver<CanonStateNotification>;

    // Provided method
    fn canonical_state_stream(&self) -> CanonStateNotificationStream { ... }
}

A type that allows to register chain related event subscriptions.

Required Methods

fn subscribe_to_canonical_state(&self) -> Receiver<CanonStateNotification>

Get notified when a new canonical chain was imported.

A canonical chain be one or more blocks, a reorg or a revert.

Provided Methods

fn canonical_state_stream(&self) -> CanonStateNotificationStream

Convenience method to get a stream of CanonStateNotification.

Implementations on Foreign Types

impl<'a, T> CanonStateSubscriptions for &'a T

where T: 'a + CanonStateSubscriptions + ?Sized, &'a T: Send + Sync,

fn subscribe_to_canonical_state(&self) -> Receiver<CanonStateNotification>

fn canonical_state_stream(&self) -> CanonStateNotificationStream

impl<T> CanonStateSubscriptions for Arc<T>

where T: CanonStateSubscriptions + ?Sized, Arc<T>: Send + Sync,

fn subscribe_to_canonical_state(&self) -> Receiver<CanonStateNotification>

fn canonical_state_stream(&self) -> CanonStateNotificationStream

Implementors

impl CanonStateSubscriptions for NoopBlockchainTree

impl CanonStateSubscriptions for NoopProvider

impl CanonStateSubscriptions for TestCanonStateSubscriptions

impl<N> CanonStateSubscriptions for BlockchainProvider2<N>

where N: NodeTypesWithDB,

impl<N> CanonStateSubscriptions for BlockchainProvider<N>

where N: ProviderNodeTypes,

impl<N, E> CanonStateSubscriptions for ShareableBlockchainTree<N, E>

where N: ProviderNodeTypes, E: Send + Sync,