Trait CanonStateSubscriptions 

pub trait CanonStateSubscriptions: Send + Sync {
    type Primitives: NodePrimitives;

    // Required method
    fn subscribe_to_canonical_state(
        &self,
    ) -> Receiver<CanonStateNotification<Self::Primitives>>;

    // Provided method
    fn canonical_state_stream(
        &self,
    ) -> CanonStateNotificationStream<Self::Primitives> { ... }
}

A type that allows to register chain related event subscriptions.

Required Associated Types

type Primitives: NodePrimitives

The node primitive types.

Required Methods

fn subscribe_to_canonical_state( &self, ) -> Receiver<CanonStateNotification<Self::Primitives>>

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<Self::Primitives>

Convenience method to get a stream of CanonStateNotification.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl<T> CanonStateSubscriptions for &T

where T: CanonStateSubscriptions,

type Primitives = <T as CanonStateSubscriptions>::Primitives

fn subscribe_to_canonical_state( &self, ) -> Receiver<CanonStateNotification<<&T as CanonStateSubscriptions>::Primitives>>

fn canonical_state_stream( &self, ) -> CanonStateNotificationStream<<&T as CanonStateSubscriptions>::Primitives>

Implementors

impl CanonStateSubscriptions for TestCanonStateSubscriptions

type Primitives = EthPrimitives

impl<C, N> CanonStateSubscriptions for NoopProvider<C, N>

where C: Send + Sync, N: NodePrimitives,

Available on crate feature chain-state only.

type Primitives = N

impl<N> CanonStateSubscriptions for BlockchainProvider<N>

where N: ProviderNodeTypes,

type Primitives = <N as NodeTypes>::Primitives

impl<T, ChainSpec> CanonStateSubscriptions for MockEthProvider<T, ChainSpec>

where T: NodePrimitives, ChainSpec: Send + Sync,

type Primitives = T