Struct NotifyController 

pub struct NotifyController { /* private fields */ }

Implementations

impl NotifyController

pub async fn subscribe_new_open_tx<S: ToString>( &self, name: S, ) -> Receiver<OpenTransaction>

pub fn notify_new_open_tx(&self, otx: OpenTransaction)

pub async fn subscribe_commit_open_tx<S: ToString>( &self, name: S, ) -> Receiver<Vec<H256>>

pub fn notify_commit_open_tx(&self, otx_hashes: Vec<H256>)

pub async fn subscribe_interval<S: ToString>(&self, name: S) -> Receiver<u64>

pub fn notify_interval(&self, elapsed_secs: u64)

pub async fn subscribe_start<S: ToString>(&self, name: S) -> Receiver<()>

pub fn notify_start(&self)

pub async fn subscribe_stop<S: ToString>(&self, name: S) -> Receiver<()>

pub fn notify_stop(&self)

Trait Implementations

impl Clone for NotifyController

fn clone(&self) -> NotifyController

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Drop for NotifyController

fn drop(&mut self)

Executes the destructor for this type.