Trait LocalObservable 

pub trait LocalObservable<'a>: Observable {
    type Unsub: SubscriptionLike + 'static;

    // Required method
    fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + 'a>(
        self,
        subscriber: Subscriber<O, LocalSubscription>,
    ) -> Self::Unsub;
}

Required Associated Types

type Unsub: SubscriptionLike + 'static

Required Methods

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

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

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

impl<'a, B, S> LocalObservable<'a> for MapToOp<S, B>

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

type Unsub = <S as LocalObservable<'a>>::Unsub

impl<'a, Emit> LocalObservable<'a> for ObservableBase<Emit>

where Emit: LocalEmitter<'a>,

type Unsub = LocalSubscription

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

type Unsub = Box<dyn SubscriptionLike>

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

type Unsub = Box<dyn SubscriptionLike>

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

type Unsub = LocalSubscription

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

type Unsub = 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 as LocalObservable<'a>>::Unsub>

impl<'a, Item, S> LocalObservable<'a> for ContainsOp<S, Item>

where S: LocalObservable<'a, Item = Item>, Item: 'a + Clone + Eq,

type Unsub = <S as LocalObservable<'a>>::Unsub

impl<'a, Item, S> LocalObservable<'a> for LastOp<S, Item>

where S: LocalObservable<'a, Item = Item>, Item: 'a + Clone,

type Unsub = <S as LocalObservable<'a>>::Unsub

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 as LocalObservable<'a>>::Unsub

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 as LocalObservable<'a>>::Unsub

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

where S: LocalObservable<'a, Item = Item>,

type Unsub = <S as LocalObservable<'a>>::Unsub

impl<'a, Outer, Inner, Item, Err> LocalObservable<'a> for FlattenOp<Outer, Inner>

where Outer: LocalObservable<'a, Item = Inner, Err = Err>, Inner: LocalObservable<'a, Item = Item, Err = Err> + 'a,

type Unsub = LocalSubscription

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 as LocalObservable<'a>>::Unsub

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

impl<'a, S> LocalObservable<'a> for BufferWithCountOp<S>

where S: LocalObservable<'a>, S::Item: 'a,

type Unsub = <S as LocalObservable<'a>>::Unsub

impl<'a, S> LocalObservable<'a> for DefaultIfEmptyOp<S>

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

type Unsub = <S as LocalObservable<'a>>::Unsub

impl<'a, S> LocalObservable<'a> for MergeAllOp<S>

where S: LocalObservable<'a>, S::Item: LocalObservable<'a, Err = S::Err> + 'a,

type Unsub = <S as LocalObservable<'a>>::Unsub

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

where S: LocalObservable<'a>,

type Unsub = <S as LocalObservable<'a>>::Unsub

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

where S: LocalObservable<'a>,

type Unsub = <S as LocalObservable<'a>>::Unsub

impl<'a, S> LocalObservable<'a> for TakeLastOp<S>

where S: LocalObservable<'a> + 'a,

type Unsub = <S as LocalObservable<'a>>::Unsub

impl<'a, S, F> LocalObservable<'a> for FilterOp<S, F>

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

type Unsub = <S as LocalObservable<'a>>::Unsub

impl<'a, S, F> LocalObservable<'a> for FinalizeOp<S, F>

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

type Unsub = <S as LocalObservable<'a>>::Unsub

impl<'a, S, F> LocalObservable<'a> for SkipWhileOp<S, F>

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

type Unsub = <S as LocalObservable<'a>>::Unsub

impl<'a, S, F> LocalObservable<'a> for TakeWhileOp<S, F>

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

type Unsub = <S as LocalObservable<'a>>::Unsub

impl<'a, S, Item> LocalObservable<'a> for DistinctOp<S>

where S: LocalObservable<'a, Item = Item>, Item: 'a + Eq + Hash + Clone,

type Unsub = <S as LocalObservable<'a>>::Unsub

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

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

type Unsub = LocalSubscription

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

impl<'a, Source, Discr, Key> LocalObservable<'a> for GroupByOp<Source, Discr>

where Source: LocalObservable<'a> + 'a + Clone, Source::Item: 'a, Discr: FnMut(&Source::Item) -> Key + 'a + Clone, Key: 'a + Hash + Clone + Eq,

type Unsub = <Source as LocalObservable<'a>>::Unsub

impl<'a, Source, Discr, Key> LocalObservable<'a> for GroupObservable<Source, Discr, Key>

where Source: LocalObservable<'a>, Source::Item: 'a, Discr: FnMut(&Source::Item) -> Key + Clone + 'a, Key: Hash + Clone + Eq + 'a,

type Unsub = <Source as LocalObservable<'a>>::Unsub

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

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

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

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 as LocalObservable<'static>>::Unsub

impl<S, SD> LocalObservable<'static> for SubscribeOnOP<S, SD>

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

type Unsub = LocalSubscription

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

impl<Source, Scheduler> LocalObservable<'static> for BufferWithCountOrTimerOp<Source, Scheduler>

where Source: LocalObservable<'static>, Source::Item: 'static, Scheduler: LocalScheduler + 'static,

type Unsub = <Source as LocalObservable<'static>>::Unsub

impl<Source, Scheduler> LocalObservable<'static> for BufferWithTimeOp<Source, Scheduler>

where Source: LocalObservable<'static>, Source::Item: 'static, Scheduler: LocalScheduler + 'static,

type Unsub = <Source as LocalObservable<'static>>::Unsub