Struct SharedSubscriber 

pub struct SharedSubscriber<Destination>
where
    Destination: Subscriber + UpgradeableObserver + Send + Sync,
{ /* private fields */ }

SharedSubscriber

This should be the very first thing you reach for when you want to share a subscriber between multiple places. Where each place with a clone of this can be sure to send signals to the exact same destination.

Deadlock Protection

While Subscriber and other traits are implemented on plain Arc<Mutex<D>>s too, and those too have uses of their own, this struct here features deadlock protection in form of a deferred notification queue.

• If the destination is not locked, the signals just go through.
• If the destination is locked, the signal materializes into the queue and when the lock is released by the holder, the queue will clear itself, applying all deferred notifications.

Implementations

impl<Destination> SharedSubscriber<Destination>

where Destination: Subscriber + UpgradeableObserver + Send + Sync,

pub fn new(destination: Destination) -> SharedSubscriber<Destination>

pub fn lock(&self) -> MutexGuard<'_, Destination>

Locks the shared destination. In case it encounters a poison error, the destination is immediately unsubscribed!

pub fn downgrade(&self) -> Weak<Mutex<Destination>>

Trait Implementations

impl<Destination> Clone for SharedSubscriber<Destination>

where Destination: Subscriber + Send + Sync,

fn clone(&self) -> SharedSubscriber<Destination>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Destination> Debug for SharedSubscriber<Destination>

where Destination: Debug + Subscriber + UpgradeableObserver + Send + Sync, <Destination as ObserverInput>::In: Debug, <Destination as ObserverInput>::InError: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<Destination> Drop for SharedSubscriber<Destination>

where Destination: Subscriber + Send + Sync,

fn drop(&mut self)

Executes the destructor for this type.

impl<Destination> ObserverInput for SharedSubscriber<Destination>

where Destination: Subscriber + UpgradeableObserver + Send + Sync,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<Destination> RxObserver for SharedSubscriber<Destination>

where Destination: 'static + Subscriber + Send + Sync,

fn next(&mut self, next: <SharedSubscriber<Destination> as ObserverInput>::In)

Signals the next value.

fn error( &mut self, error: <SharedSubscriber<Destination> as ObserverInput>::InError, )

Signals an error of upstream, no more next or complete calls are expected after this!

fn complete(&mut self)

Signals the completion of upstream, no more next or error calls are expected after this!

impl<Destination> SharedDestination<Destination> for SharedSubscriber<Destination>

where Destination: 'static + Subscriber + Send + Sync,

fn access<F>(&mut self, accessor: F)

where F: Fn(&Destination),

fn access_mut<F>(&mut self, accessor: F)

where F: FnMut(&mut Destination),

impl<Destination> SubscriptionLike for SharedSubscriber<Destination>

where Destination: 'static + Subscriber + Send + Sync,

fn is_closed(&self) -> bool

Returns if the subscription is closed or not. A subscription can be closed by calling unsubscribe on it. Some special subscriptions made by observables that only ever emit values during subscribe, will produce subscriptions that are created closed.

fn unsubscribe(&mut self)

Releases all resources associated with this subscription, and marks it as closed.

impl<Destination> TeardownCollection for SharedSubscriber<Destination>

where Destination: Subscriber + UpgradeableObserver + Send + Sync,

fn add_teardown(&mut self, teardown: Teardown)

Add additional teardowns to execute on unsubscribe. If the subscription is already closed, the added teardown is immediately executed!

impl<Destination> WithPrimaryCategory for SharedSubscriber<Destination>

where Destination: Subscriber + UpgradeableObserver + Send + Sync,

type PrimaryCategory = PrimaryCategorySubscriber

impl<Destination> ObserverUpgradesToSelf for SharedSubscriber<Destination>

where Destination: Subscriber + UpgradeableObserver + Send + Sync,