Struct sc_client_api::notifications::StorageNotifications

pub struct StorageNotifications<Block: BlockT> { /* fields omitted */ }

Manages storage listeners.

Implementations

impl<Block: BlockT> StorageNotifications<Block>

pub fn new(prometheus_registry: Option<Registry>) -> Self

Initialize a new StorageNotifications optionally pass a prometheus registry to send subscriber metrics to

pub fn trigger(
    &mut self,
    hash: &Block::Hash,
    changeset: impl Iterator<Item = (Vec<u8>, Option<Vec<u8>>)>,
    child_changeset: impl Iterator<Item = (Vec<u8>, impl Iterator<Item = (Vec<u8>, Option<Vec<u8>>)>)>
)

Trigger notification to all listeners.

Note the changes are going to be filtered by listener's filter key. In fact no event might be sent if clients are not interested in the changes.

pub fn listen(
    &mut self,
    filter_keys: Option<&[StorageKey]>,
    filter_child_keys: Option<&[(StorageKey, Option<Vec<StorageKey>>)]>
) -> StorageEventStream<Block::Hash>

Start listening for particular storage keys.

Trait Implementations

impl<Block: Debug + BlockT> Debug for StorageNotifications<Block> where
    Block::Hash: Debug, 

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<Block: BlockT> Default for StorageNotifications<Block>

fn default() -> Self

Returns the "default value" for a type.