Trait rxrust::shared::SharedObservable

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

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

Associated Types

type Unsub: SubscriptionLike + 'static

Required methods

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

Provided methods

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

Convert to a thread-safe mode.

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

impl<'a, Source, Discr, Key> SharedObservable for GroupByOp<Source, Discr> where
    Source: SharedObservable + Clone + Send + Sync + 'static,
    Source::Item: Send + Sync + 'static,
    Discr: FnMut(&Source::Item) -> Key + Clone + Send + Sync + 'static,
    Key: 'a + Hash + Clone + Eq + Send + Sync + 'static, 

type Unsub = Source::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

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

type Unsub = S::Unsub

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

type Unsub = SharedSubscription

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

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

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

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

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

type Unsub = SharedSubscription

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

type Unsub = SharedSubscription

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>

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

type Unsub = S::Unsub

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

type Unsub = S::Unsub

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

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

impl<Outer, Inner, Item, Err> SharedObservable for FlattenOp<Outer, Inner> where
    Outer: SharedObservable<Item = Inner, Err = Err>,
    Outer::Unsub: Send + Sync,
    Inner: SharedObservable<Item = Item, Err = Err, Unsub = SharedSubscription> + Send + Sync + 'static, 

type Unsub = SharedSubscription

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

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

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

type Unsub = S::Unsub

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

type Unsub = S::Unsub

impl<S> SharedObservable for MergeAllOp<S> where
    S: SharedObservable,
    S::Err: Send + Sync + 'static,
    S::Item: SharedObservable<Err = S::Err> + Send + Sync + 'static,
    <S::Item as SharedObservable>::Unsub: Send + Sync + 'static,
    Self::Item: Send + Sync + 'static, 

type Unsub = S::Unsub

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

type Unsub = S::Unsub

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

type Unsub = S::Unsub

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

type Unsub = S::Unsub

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

type Unsub = S::Unsub

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

type Unsub = S::Unsub

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

type Unsub = S::Unsub

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

type Unsub = S::Unsub

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

type Unsub = S::Unsub

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

type Unsub = S::Unsub

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

type Unsub = S::Unsub

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

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

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

type Unsub = 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

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

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

type Unsub = S::Unsub

impl<Source, Discr, Key> SharedObservable for GroupObservable<Source, Discr, Key> where
    Source: SharedObservable,
    Source::Item: Send + Sync + 'static,
    Discr: FnMut(&Source::Item) -> Key + Clone + Send + Sync + 'static,
    Key: Hash + Clone + Eq + Send + Sync + 'static, 

type Unsub = Source::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

impl<Source, Scheduler> SharedObservable for BufferWithCountOrTimerOp<Source, Scheduler> where
    Source: SharedObservable,
    Source::Item: Send + Sync + 'static,
    Scheduler: SharedScheduler, 

type Unsub = Source::Unsub

impl<Source, Scheduler> SharedObservable for BufferWithTimeOp<Source, Scheduler> where
    Source: SharedObservable,
    <Source as Observable>::Item: Send + Sync + 'static,
    Scheduler: SharedScheduler, 

type Unsub = Source::Unsub