NotifyController

Struct NotifyController 

Source
pub struct NotifyController { /* private fields */ }
Expand description

Controller for the notification service.

Provides methods to subscribe to various blockchain events and notify subscribers of new blocks, transactions, and network alerts.

Implementations§

Source§

impl NotifyController

Source

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

Subscribes to new block notifications with the given name.

Returns a receiver channel that will receive new block events.

Source

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

watch new block notify

Source

pub fn notify_new_block(&self, block: BlockView)

Notifies all subscribers of a new block.

Source

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

Subscribes to new transaction notifications with the given name.

Returns a receiver channel that will receive new transaction events from the transaction pool.

Source

pub fn notify_new_transaction(&self, tx_entry: PoolTransactionEntry)

Notifies all subscribers of a new transaction in the transaction pool.

Source

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

Subscribes to proposed transaction notifications with the given name.

Returns a receiver channel that will receive proposed transaction events.

Source

pub fn notify_proposed_transaction(&self, tx_entry: PoolTransactionEntry)

Notifies all subscribers of a proposed transaction.

Source

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

Subscribes to rejected transaction notifications with the given name.

Returns a receiver channel that will receive rejected transaction events.

Source

pub fn notify_reject_transaction( &self, tx_entry: PoolTransactionEntry, reject: Reject, )

Notifies all subscribers of a rejected transaction.

Source

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

Subscribes to network alert notifications with the given name.

Returns a receiver channel that will receive network alert events.

Source

pub fn notify_network_alert(&self, alert: Alert)

Notifies all subscribers of a network alert.

Trait Implementations§

Source§

impl Clone for NotifyController

Source§

fn clone(&self) -> NotifyController

Returns a duplicate of the value. Read more
1.0.0§

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

Performs copy-assignment from source. Read more

Auto Trait Implementations§

Blanket Implementations§

§

impl<T> Any for T
where T: 'static + ?Sized,

§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> AsAny for T
where T: Any,

Source§

fn as_any(&self) -> &(dyn Any + 'static)

Cast to trait Any
§

impl<T> Borrow<T> for T
where T: ?Sized,

§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
§

impl<T> BorrowMut<T> for T
where T: ?Sized,

§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
§

impl<T> CloneToUninit for T
where T: Clone,

§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> DynClone for T
where T: Clone,

Source§

fn __clone_box(&self, _: Private) -> *mut ()

§

impl<T> From<T> for T

§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T, U> Into<U> for T
where U: From<T>,

§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
§

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

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

The type returned in the event of a conversion error.
§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

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

Source§

fn vzip(self) -> V

Source§

impl<T> ErasedDestructor for T
where T: 'static,