Struct fp_rust::common::SubscriptionFunc

pub struct SubscriptionFunc<T> {
    pub receiver: RawReceiver<T>,
    // some fields omitted
}

Fields

receiver: RawReceiver<T>

Methods

impl<T: Send + Sync + 'static + Clone> SubscriptionFunc<T>

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

Trait Implementations

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

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

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

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

impl<T: Clone> Clone for SubscriptionFunc<T>

fn clone(&self) -> SubscriptionFunc<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

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

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

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

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