Struct SubscriptionFunc

pub struct SubscriptionFunc<T> {
    pub receiver: RawReceiver<T>,
    /* private fields */
}

SubscriptionFunc struct implements the interface of Subscription, for general purposes crossing over many modules of fpRust.

Arguments

• T - The generic type of broadcasted data

Remarks

It’s enough to use for general cases of Subscription.

Fields

receiver: RawReceiver<T>

Implementations

impl<T> SubscriptionFunc<T>

pub fn new( func: impl FnMut(Arc<T>) + Send + Sync + 'static, ) -> SubscriptionFunc<T>

Trait Implementations

impl<T> Clone for SubscriptionFunc<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<X: Send + Sync + 'static> Observable<X, SubscriptionFunc<X>> for Publisher<X>

fn add_observer(&mut self, observer: Arc<SubscriptionFunc<X>>)

Add a Subscription.

fn delete_observer(&mut self, observer: Arc<SubscriptionFunc<X>>)

Remove the observer.

fn notify_observers(&mut self, val: Arc<X>)

Notify all Subscription subscribers with a given value Arc<X>.

impl<T> PartialEq for SubscriptionFunc<T>

fn eq(&self, other: &SubscriptionFunc<T>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<T: Send + Sync + 'static> Subscription<T> for SubscriptionFunc<T>

fn on_next(&self, x: Arc<T>)

The callback when Subscription received the broadcasted value.

impl<T> UniqueId<String> for SubscriptionFunc<T>

fn get_id(&self) -> String

The callback when Subscription received the broadcasted value.