[][src]Struct sc_client_api::notifications::StorageNotifications

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

Manages storage listeners.

Implementations

impl<Block: BlockT> StorageNotifications<Block>[src]

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

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>>)>)>
)
[src]

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>
[src]

Start listening for particular storage keys.

Trait Implementations

impl<Block: Debug + BlockT> Debug for StorageNotifications<Block> where
    Block::Hash: Debug
[src]

impl<Block: BlockT> Default for StorageNotifications<Block>[src]

Auto Trait Implementations

impl<Block> !RefUnwindSafe for StorageNotifications<Block>[src]

impl<Block> Send for StorageNotifications<Block> where
    <Block as Block>::Hash: Send
[src]

impl<Block> Sync for StorageNotifications<Block> where
    <Block as Block>::Hash: Send
[src]

impl<Block> Unpin for StorageNotifications<Block>[src]

impl<Block> !UnwindSafe for StorageNotifications<Block>[src]

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> CheckedConversion for T[src]

impl<T> From<T> for T[src]

impl<T> Instrument for T[src]

impl<T> Instrument for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T, Outer> IsWrappedBy<Outer> for T where
    T: From<Outer>,
    Outer: AsRef<T> + AsMut<T> + From<T>, 
[src]

pub fn from_ref(outer: &Outer) -> &T[src]

Get a reference to the inner from the outer.

pub fn from_mut(outer: &mut Outer) -> &mut T[src]

Get a mutable reference to the inner from the outer.

impl<T> MaybeDebug for T where
    T: Debug

impl<T> MaybeDebug for T where
    T: Debug

impl<T> Pointable for T

type Init = T

The type for initializers.

impl<T> Same<T> for T

type Output = T

Should always be Self

impl<T> SaturatedConversion for T[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<S, T> UncheckedInto<T> for S where
    T: UncheckedFrom<S>, 
[src]

impl<T, S> UniqueSaturatedInto<T> for S where
    T: Bounded,
    S: TryInto<T>, 
[src]

impl<V, T> VZip<V> for T where
    V: MultiLane<T>, 

impl<T> WithSubscriber for T[src]