Struct fp_rust::publisher::Publisher [−][src]
pub struct Publisher<X, T> { /* fields omitted */ }Methods
impl<X: Send + Sync + 'static + Clone> Publisher<X, SubscriptionFunc<X>>[src]
impl<X: Send + Sync + 'static + Clone> Publisher<X, SubscriptionFunc<X>>pub fn new() -> Publisher<X, SubscriptionFunc<X>>[src]
pub fn new() -> Publisher<X, SubscriptionFunc<X>>pub fn new_with_handlers(
h: Option<Arc<Mutex<Handler + 'static>>>
) -> Publisher<X, SubscriptionFunc<X>>[src]
pub fn new_with_handlers(
h: Option<Arc<Mutex<Handler + 'static>>>
) -> Publisher<X, SubscriptionFunc<X>>pub fn publish(&mut self, val: X)[src]
pub fn publish(&mut self, val: X)pub fn subscribe(
&mut self,
s: Arc<SubscriptionFunc<X>>
) -> Arc<SubscriptionFunc<X>>[src]
pub fn subscribe(
&mut self,
s: Arc<SubscriptionFunc<X>>
) -> Arc<SubscriptionFunc<X>>pub fn subscribe_fn(
&mut self,
func: impl FnMut(Arc<X>) + Send + Sync + 'static
) -> Arc<SubscriptionFunc<X>>[src]
pub fn subscribe_fn(
&mut self,
func: impl FnMut(Arc<X>) + Send + Sync + 'static
) -> Arc<SubscriptionFunc<X>>pub fn map<Z: Send + Sync + 'static + Clone>(
&mut self,
func: impl FnMut(Arc<X>) -> Z + Send + Sync + 'static + Clone
) -> Arc<SubscriptionFunc<X>>[src]
pub fn map<Z: Send + Sync + 'static + Clone>(
&mut self,
func: impl FnMut(Arc<X>) -> Z + Send + Sync + 'static + Clone
) -> Arc<SubscriptionFunc<X>>pub fn unsubscribe(&mut self, s: Arc<SubscriptionFunc<X>>)[src]
pub fn unsubscribe(&mut self, s: Arc<SubscriptionFunc<X>>)pub fn subscribe_on(&mut self, h: Option<Arc<Mutex<Handler + 'static>>>)[src]
pub fn subscribe_on(&mut self, h: Option<Arc<Mutex<Handler + 'static>>>)Trait Implementations
impl<X: Clone, T: Clone> Clone for Publisher<X, T>[src]
impl<X: Clone, T: Clone> Clone for Publisher<X, T>fn clone(&self) -> Publisher<X, T>[src]
fn clone(&self) -> Publisher<X, T>Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)1.0.0[src]
fn clone_from(&mut self, source: &Self)1.0.0
[src]Performs copy-assignment from source. Read more
impl<X: Send + Sync + 'static + Clone> Observable<X, SubscriptionFunc<X>> for Publisher<X, SubscriptionFunc<X>>[src]
impl<X: Send + Sync + 'static + Clone> Observable<X, SubscriptionFunc<X>> for Publisher<X, SubscriptionFunc<X>>fn add_observer(&mut self, observer: Arc<SubscriptionFunc<X>>)[src]
fn add_observer(&mut self, observer: Arc<SubscriptionFunc<X>>)fn delete_observer(&mut self, observer: Arc<SubscriptionFunc<X>>)[src]
fn delete_observer(&mut self, observer: Arc<SubscriptionFunc<X>>)fn notify_observers(&mut self, val: Arc<X>)[src]
fn notify_observers(&mut self, val: Arc<X>)