Trait rxrust::shared::SharedObservable

pub trait SharedObservable: Observable {
    type Unsub: SubscriptionLike + 'static;
    pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Sync + Send + 'static>(
        self, 
        subscriber: Subscriber<O, SharedSubscription>
    ) -> Self::Unsub;

    pub fn to_shared(self) -> Shared<Self>
    where
        Self: Sized,
    { ... }
}

Associated Types

type Unsub: SubscriptionLike + 'static

Loading content...

Required methods

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Sync + Send + 'static>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub

Loading content...

Provided methods

pub fn to_shared(self) -> Shared<Self> where
    Self: Sized, 

Convert to a thread-safe mode.

Loading content...

Implementors

impl<'a, S, SD> SharedObservable for SubscribeOnOP<S, SD> where
    S: SharedObservable + Send + 'static,
    SD: SharedScheduler + Send + 'static,
    S::Unsub: Send + Sync, 

type Unsub = SharedSubscription

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Sync + Send + 'static>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub

impl<A, B> SharedObservable for ZipOp<A, B> where
    A: SharedObservable,
    B: SharedObservable<Err = A::Err>,
    A::Item: Send + Sync + 'static,
    B::Item: Send + Sync + 'static,
    A::Unsub: Send + Sync,
    B::Unsub: Send + Sync, 

type Unsub = SharedSubscription

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Sync + Send + 'static>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub

impl<B, S> SharedObservable for MapToOp<S, B> where
    S: SharedObservable,
    B: Clone + Send + Sync + 'static,
    S::Item: 'static, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<Emit> SharedObservable for ObservableBase<Emit> where
    Emit: SharedEmitter, 

type Unsub = SharedSubscription

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<Item, Err> SharedObservable for SharedBoxOp<Item, Err>

type Unsub = Box<dyn SubscriptionLike + Send + Sync>

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<Item, Err> SharedObservable for SharedCloneBoxOp<Item, Err>

type Unsub = Box<dyn SubscriptionLike + Send + Sync>

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<Item, Err> SharedObservable for SharedSubject<Item, Err>

type Unsub = SharedSubscription

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Sync + Send + 'static>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub

impl<Item, Err, S> SharedObservable for SharedRefCount<S, Item, Err> where
    S: SharedObservable<Item = Item, Err = Err> + Clone,
    S::Unsub: Clone,
    Item: Clone + Send + Sync + 'static,
    Err: Clone + Send + Sync + 'static, 

type Unsub = RefCountSubscription<SharedSubscription, S::Unsub>

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Sync + Send + 'static>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub

impl<Item, S> SharedObservable for LastOrOp<S, Item> where
    S: SharedObservable<Item = Item>,
    Item: Send + Sync + 'static, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<Item, S, F> SharedObservable for FilterMapOp<S, F> where
    S: SharedObservable,
    F: FnMut(S::Item) -> Option<Item> + Send + Sync + 'static,
    S::Item: 'static, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<Item, S, M> SharedObservable for MapOp<S, M> where
    S: SharedObservable,
    M: FnMut(S::Item) -> Item + Send + Sync + 'static,
    S::Item: 'static, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<OutputItem, Source, BinaryOp> SharedObservable for ScanOp<Source, BinaryOp, OutputItem> where
    Source: SharedObservable,
    OutputItem: Clone + Send + Sync + 'static,
    Source::Item: 'static,
    BinaryOp: FnMut(OutputItem, Source::Item) -> OutputItem + Send + Sync + 'static, 

type Unsub = Source::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<S1, S2> SharedObservable for MergeOp<S1, S2> where
    S1: SharedObservable,
    S2: SharedObservable<Item = S1::Item, Err = S1::Err, Unsub = S1::Unsub>,
    S1::Unsub: Send + Sync, 

type Unsub = SharedSubscription

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Sync + Send + 'static>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub

impl<S> SharedObservable for DefaultIfEmptyOp<S> where
    S: SharedObservable,
    S::Item: Clone + Send + Sync + 'static, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<S> SharedObservable for DistinctOp<S> where
    S: SharedObservable,
    S::Item: Clone + Send + 'static + Eq + Hash, 

type Unsub = S::Unsub

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Sync + Send + 'static>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> S::Unsub

impl<S> SharedObservable for SkipOp<S> where
    S: SharedObservable, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<S> SharedObservable for SkipLastOp<S> where
    S: SharedObservable,
    S::Item: Send + Sync + 'static, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<S> SharedObservable for TakeOp<S> where
    S: SharedObservable, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<S> SharedObservable for TakeLastOp<S> where
    S: SharedObservable,
    S::Item: Send + Sync + 'static, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<S> SharedObservable for Shared<S> where
    S: SharedObservable, 

type Unsub = S::Unsub

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Sync + Send + 'static>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub

impl<S, F> SharedObservable for FilterOp<S, F> where
    S: SharedObservable,
    F: FnMut(&S::Item) -> bool + Send + Sync + 'static, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<S, F> SharedObservable for FinalizeOp<S, F> where
    S: SharedObservable,
    F: FnMut() + Send + Sync + 'static,
    S::Unsub: Send + Sync, 

type Unsub = S::Unsub

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Sync + Send + 'static>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub

impl<S, F> SharedObservable for TakeWhileOp<S, F> where
    S: SharedObservable,
    F: FnMut(&S::Item) -> bool + Send + Sync + 'static, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<S, Item> SharedObservable for FirstOrOp<S, Item> where
    S: SharedObservable<Item = Item>,
    Item: Send + Sync + 'static, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<S, Item, Err> SharedObservable for SharedConnectableObservable<S, Item, Err> where
    S: SharedObservable<Item = Item, Err = Err>,
    S: SharedObservable<Item = Item, Err = Err>, 

type Unsub = SharedSubscription

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<S, N> SharedObservable for TakeUntilOp<S, N> where
    S: SharedObservable,
    N: SharedObservable<Err = S::Err>,
    S::Item: Send + Sync + 'static,
    N::Item: Send + Sync + 'static,
    S::Unsub: Send + Sync,
    N::Unsub: Send + Sync, 

type Unsub = SharedSubscription

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static, 

impl<S, SD> SharedObservable for DebounceOp<S, SD> where
    S: SharedObservable,
    S::Item: Clone + Send + 'static,
    SD: SharedScheduler + Send + 'static, 

type Unsub = S::Unsub

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Sync + Send + 'static>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> S::Unsub

impl<S, SD> SharedObservable for DelayOp<S, SD> where
    S: SharedObservable + Send + Sync + 'static,
    S::Unsub: Send + Sync,
    SD: SharedScheduler, 

type Unsub = SharedSubscription

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Sync + Send + 'static>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub

impl<S, SD> SharedObservable for ObserveOnOp<S, SD> where
    S: SharedObservable,
    S::Item: Clone + Send + 'static,
    S::Err: Clone + Send + 'static,
    SD: SharedScheduler + Send + Sync + 'static, 

type Unsub = S::Unsub

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Sync + Send + 'static>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub

impl<S, SD> SharedObservable for ThrottleTimeOp<S, SD> where
    S: SharedObservable,
    S::Item: Clone + Send + 'static,
    SD: SharedScheduler + Send + 'static, 

type Unsub = S::Unsub

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Sync + Send + 'static>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> S::Unsub

impl<Source, Sampling> SharedObservable for SampleOp<Source, Sampling> where
    Source: SharedObservable,
    Source::Item: Send + Sync + 'static + Clone,
    Source::Unsub: Send + Sync,
    Source::Err: Send + Sync + 'static,
    Sampling: SharedObservable<Err = Source::Err>,
    Sampling::Item: Send + Sync + 'static + Clone,
    Sampling::Unsub: Send + Sync, 

type Unsub = SharedSubscription

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static>(
    self,
    subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub

Loading content...