Trait sc_client_api::client::BlockchainEvents
source · pub trait BlockchainEvents<Block: BlockT> {
// Required methods
fn import_notification_stream(&self) -> ImportNotifications<Block>;
fn every_import_notification_stream(&self) -> ImportNotifications<Block>;
fn finality_notification_stream(&self) -> FinalityNotifications<Block>;
fn storage_changes_notification_stream(
&self,
filter_keys: Option<&[StorageKey]>,
child_filter_keys: Option<&[(StorageKey, Option<Vec<StorageKey>>)]>,
) -> Result<StorageEventStream<Block::Hash>>;
}
Expand description
A source of blockchain events.
Required Methods§
sourcefn import_notification_stream(&self) -> ImportNotifications<Block>
fn import_notification_stream(&self) -> ImportNotifications<Block>
Get block import event stream.
Not guaranteed to be fired for every imported block, only fired when the node
has synced to the tip or there is a re-org. Use every_import_notification_stream()
if you want a notification of every imported block regardless.
sourcefn every_import_notification_stream(&self) -> ImportNotifications<Block>
fn every_import_notification_stream(&self) -> ImportNotifications<Block>
Get a stream of every imported block.
sourcefn finality_notification_stream(&self) -> FinalityNotifications<Block>
fn finality_notification_stream(&self) -> FinalityNotifications<Block>
Get a stream of finality notifications. Not guaranteed to be fired for every finalized block.
sourcefn storage_changes_notification_stream(
&self,
filter_keys: Option<&[StorageKey]>,
child_filter_keys: Option<&[(StorageKey, Option<Vec<StorageKey>>)]>,
) -> Result<StorageEventStream<Block::Hash>>
fn storage_changes_notification_stream( &self, filter_keys: Option<&[StorageKey]>, child_filter_keys: Option<&[(StorageKey, Option<Vec<StorageKey>>)]>, ) -> Result<StorageEventStream<Block::Hash>>
Get storage changes event stream.
Passing None
as filter_keys
subscribes to all storage changes.