Trait rxrust::observable::LocalObservable

pub trait LocalObservable<'a>: Observable {
    type Unsub: SubscriptionLike + 'static;
    pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + 'a>(
        self, 
        subscriber: Subscriber<O, LocalSubscription>
    ) -> Self::Unsub;
}

Associated Types

type Unsub: SubscriptionLike + 'static

Loading content...

Required methods

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + 'a>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub

Loading content...

Implementors

impl<'a, A, B> LocalObservable<'a> for ZipOp<A, B> where
    A: LocalObservable<'a>,
    B: LocalObservable<'a, Err = A::Err>,
    A::Item: 'a,
    B::Item: 'a, 

type Unsub = LocalSubscription

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + 'a>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub

impl<'a, B, S> LocalObservable<'a> for MapToOp<S, B> where
    S: LocalObservable<'a>,
    B: Clone + 'a,
    S::Item: 'a, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, Emit> LocalObservable<'a> for ObservableBase<Emit> where
    Emit: LocalEmitter<'a>, 

type Unsub = LocalSubscription

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, Item, Err> LocalObservable<'a> for LocalBoxOp<'a, Item, Err>

type Unsub = Box<dyn SubscriptionLike>

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, Item, Err> LocalObservable<'a> for LocalCloneBoxOp<'a, Item, Err>

type Unsub = Box<dyn SubscriptionLike>

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, Item, Err> LocalObservable<'a> for LocalSubject<'a, Item, Err>

type Unsub = LocalSubscription

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + 'a>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> LocalSubscription

impl<'a, Item, Err, S> LocalObservable<'a> for LocalRefCount<'a, S, Item, Err> where
    S: LocalObservable<'a, Item = Item, Err = Err> + Clone,
    S::Unsub: Clone,
    Item: Clone + 'a,
    Err: Clone + 'a, 

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

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + 'a>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub

impl<'a, Item, S> LocalObservable<'a> for LastOrOp<S, Item> where
    S: LocalObservable<'a, Item = Item>,
    Item: 'a, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, Item, S, F> LocalObservable<'a> for FilterMapOp<S, F> where
    S: LocalObservable<'a>,
    F: FnMut(S::Item) -> Option<Item> + 'a,
    S::Item: 'a, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, Item, S, M> LocalObservable<'a> for MapOp<S, M> where
    S: LocalObservable<'a>,
    M: FnMut(S::Item) -> Item + 'a,
    S::Item: 'a, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, Item: 'a, S> LocalObservable<'a> for SkipLastOp<S> where
    S: LocalObservable<'a, Item = Item>, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, OutputItem, Source, BinaryOp> LocalObservable<'a> for ScanOp<Source, BinaryOp, OutputItem> where
    Source: LocalObservable<'a>,
    OutputItem: Clone + 'a,
    BinaryOp: FnMut(OutputItem, Source::Item) -> OutputItem + 'a,
    Source::Item: 'a, 

type Unsub = Source::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, S1, S2> LocalObservable<'a> for MergeOp<S1, S2> where
    S1: LocalObservable<'a>,
    S2: LocalObservable<'a, Item = S1::Item, Err = S1::Err>, 

type Unsub = LocalSubscription

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + 'a>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub

impl<'a, S> LocalObservable<'a> for DefaultIfEmptyOp<S> where
    S: LocalObservable<'a>,
    S::Item: Clone + 'a, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, S> LocalObservable<'a> for SkipOp<S> where
    S: LocalObservable<'a>, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, S> LocalObservable<'a> for TakeOp<S> where
    S: LocalObservable<'a>, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, S> LocalObservable<'a> for TakeLastOp<S> where
    S: LocalObservable<'a> + 'a, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, S, F> LocalObservable<'a> for FilterOp<S, F> where
    S: LocalObservable<'a>,
    F: FnMut(&S::Item) -> bool + 'a, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, S, F> LocalObservable<'a> for FinalizeOp<S, F> where
    S: LocalObservable<'a>,
    F: FnMut() + 'static, 

type Unsub = S::Unsub

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + 'a>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub

impl<'a, S, F> LocalObservable<'a> for TakeWhileOp<S, F> where
    S: LocalObservable<'a>,
    F: FnMut(&S::Item) -> bool + 'a, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, S, Item> LocalObservable<'a> for FirstOrOp<S, Item> where
    S: LocalObservable<'a, Item = Item>,
    Item: 'a, 

type Unsub = S::Unsub

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, S, Item, Err> LocalObservable<'a> for LocalConnectableObservable<'a, S, Item, Err> where
    S: LocalObservable<'a, Item = Item, Err = Err>, 

type Unsub = LocalSubscription

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, S, N> LocalObservable<'a> for TakeUntilOp<S, N> where
    S: LocalObservable<'a> + 'a,
    N: LocalObservable<'a, Err = S::Err> + 'a, 

type Unsub = LocalSubscription

pub fn actual_subscribe<O>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub where
    O: Observer<Item = Self::Item, Err = Self::Err> + 'a, 

impl<'a, Source, Sampling> LocalObservable<'a> for SampleOp<Source, Sampling> where
    Source: LocalObservable<'a> + 'a,
    Sampling: LocalObservable<'a, Err = Source::Err> + 'a, 

type Unsub = LocalSubscription

pub fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + 'a>(
    self,
    subscriber: Subscriber<O, LocalSubscription>
) -> Self::Unsub

impl<Item, Err, S, SD, Unsub> LocalObservable<'static> for DebounceOp<S, SD> where
    S: LocalObservable<'static, Item = Item, Err = Err, Unsub = Unsub>,
    Unsub: SubscriptionLike + 'static,
    Item: Clone + 'static,
    SD: LocalScheduler + 'static, 

type Unsub = Unsub

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

impl<Item, Err, S, SD, Unsub> LocalObservable<'static> for ThrottleTimeOp<S, SD> where
    S: LocalObservable<'static, Item = Item, Err = Err, Unsub = Unsub>,
    Unsub: SubscriptionLike + 'static,
    Item: Clone + 'static,
    SD: LocalScheduler + 'static, 

type Unsub = Unsub

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

impl<S, SD> LocalObservable<'static> for ObserveOnOp<S, SD> where
    S: LocalObservable<'static>,
    S::Item: Clone + 'static,
    S::Err: Clone + 'static,
    SD: LocalScheduler + 'static, 

type Unsub = S::Unsub

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

impl<S, SD> LocalObservable<'static> for SubscribeOnOP<S, SD> where
    S: LocalObservable<'static> + 'static,
    SD: LocalScheduler, 

type Unsub = LocalSubscription

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

impl<S, SD, Unsub> LocalObservable<'static> for DelayOp<S, SD> where
    S: LocalObservable<'static, Unsub = Unsub> + 'static,
    Unsub: SubscriptionLike + 'static,
    SD: LocalScheduler, 

type Unsub = LocalSubscription

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

impl<S, Unsub> LocalObservable<'static> for DistinctOp<S> where
    S: LocalObservable<'static, Unsub = Unsub>,
    Unsub: SubscriptionLike + 'static,
    S::Item: Clone + 'static + Hash + Eq, 

type Unsub = Unsub

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

Loading content...