Trait rxrust::observable::LocalObservable

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

Associated Types

type Unsub: SubscriptionLike

Required methods

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

Implementors

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

type Unsub = S::Unsub

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 + 'a>

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

type Unsub = MutRc<SingleSubscription>

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

type Unsub = S::Unsub

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

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

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

type Unsub = MutRc<SingleSubscription>

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

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

type Unsub = S::Unsub

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

type Unsub = FinalizerSubscription<S::Unsub, Rc<RefCell<Option<F>>>>

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

type Unsub = S::Unsub

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

type Unsub = S::Unsub

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::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::Unsub

impl<'o> LocalObservable<'o> for NeverObservable

type Unsub = SingleSubscription

impl<'o, A, B> LocalObservable<'o> for WithLatestFromOp<A, B> where
    A: LocalObservable<'o>,
    B: LocalObservable<'o, Err = A::Err>,
    A::Item: 'o,
    B::Item: Clone + 'o,
    A::Unsub: 'static,
    B::Unsub: 'static, 

type Unsub = RcMultiSubscription

impl<'o, A, B> LocalObservable<'o> for ZipOp<A, B> where
    A: LocalObservable<'o>,
    B: LocalObservable<'o, Err = A::Err>,
    A::Item: 'o,
    B::Item: 'o,
    A::Unsub: 'static,
    B::Unsub: 'static, 

type Unsub = RcMultiSubscription

impl<'o, A, B, BinaryOp, OutputItem> LocalObservable<'o> for CombineLatestOp<A, B, BinaryOp> where
    A: LocalObservable<'o>,
    B: LocalObservable<'o, Err = A::Err>,
    BinaryOp: FnMut(A::Item, B::Item) -> OutputItem + 'o,
    A::Item: Clone + 'o,
    B::Item: Clone + 'o,
    A::Unsub: 'static,
    B::Unsub: 'static, 

type Unsub = RcMultiSubscription

impl<'o, Err> LocalObservable<'o> for ThrowObservable<Err>

type Unsub = SingleSubscription

impl<'o, F, Item, Err> LocalObservable<'o> for ObservableFn<F, Item, Err> where
    F: FnOnce(&mut dyn Observer<Item = Item, Err = Err>), 

type Unsub = SingleSubscription

impl<'o, F, U> LocalObservable<'o> for ObservableDeref<F> where
    F: FnOnce() -> U,
    U: LocalObservable<'o>, 

type Unsub = U::Unsub

impl<'o, Item> LocalObservable<'o> for OfObservable<Item>

type Unsub = SingleSubscription

impl<'o, Item> LocalObservable<'o> for OptionObservable<Item>

type Unsub = SingleSubscription

impl<'o, Item> LocalObservable<'o> for EmptyObservable<Item>

type Unsub = SingleSubscription

impl<'o, Item, Err> LocalObservable<'o> for ResultObservable<Item, Err>

type Unsub = SingleSubscription

impl<'o, Item, F> LocalObservable<'o> for CallableObservable<F> where
    F: FnOnce() -> Item, 

type Unsub = SingleSubscription

impl<'o, Item, S> LocalObservable<'o> for TimerObservable<Item, S> where
    'o: 'static,
    S: Scheduler + 'static,
    Item: 'static, 

type Unsub = SpawnHandle

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

type Unsub = S::Unsub

impl<'o, Outer, Inner> LocalObservable<'o> for FlattenOp<Outer, Inner> where
    Inner: LocalObservable<'o> + 'o,
    Outer: LocalObservable<'o, Item = Inner, Err = Inner::Err>,
    Inner::Unsub: 'static,
    Outer::Unsub: 'static, 

type Unsub = RcMultiSubscription

impl<'o, S1, S2> LocalObservable<'o> for MergeOp<S1, S2> where
    S1: LocalObservable<'o>,
    S2: LocalObservable<'o, Item = S1::Item, Err = S1::Err>,
    S1::Unsub: 'static,
    S2::Unsub: 'static, 

type Unsub = RcMultiSubscription

impl<'o, S> LocalObservable<'o> for BufferWithCountOp<S> where
    S: LocalObservable<'o>,
    S::Item: 'o, 

type Unsub = S::Unsub

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

type Unsub = S::Unsub

impl<'o, S> LocalObservable<'o> for DistinctOp<S> where
    S: LocalObservable<'o>,
    S::Item: Eq + Hash + Clone + 'o, 

type Unsub = S::Unsub

impl<'o, S> LocalObservable<'o> for SkipOp<S> where
    S::Unsub: 'o,
    S: LocalObservable<'o>, 

type Unsub = Rc<ProxySubscription<S::Unsub>>

impl<'o, S> LocalObservable<'o> for SkipLastOp<S> where
    S: LocalObservable<'o> + 'o, 

type Unsub = S::Unsub

impl<'o, S> LocalObservable<'o> for TakeOp<S> where
    S::Unsub: 'o,
    S: LocalObservable<'o>, 

type Unsub = Rc<ProxySubscription<S::Unsub>>

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

type Unsub = S::Unsub

impl<'o, S> LocalObservable<'o> for IntervalObservable<S> where
    'o: 'static,
    S: Scheduler + 'static, 

type Unsub = SpawnHandle

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

type Unsub = S::Unsub

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

type Unsub = Rc<ProxySubscription<S::Unsub>>

impl<'o, S, N> LocalObservable<'o> for TakeUntilOp<S, N> where
    S: LocalObservable<'o>,
    N: LocalObservable<'o, Err = S::Err> + 'o,
    S::Unsub: 'static,
    N::Unsub: 'static, 

type Unsub = RcMultiSubscription

impl<'o, S, SD> LocalObservable<'o> for DebounceOp<S, SD> where
    'o: 'static,
    S: LocalObservable<'o>,
    S::Item: Clone + 'static,
    SD: Scheduler + 'static, 

type Unsub = S::Unsub

impl<'o, S, SD> LocalObservable<'o> for DelayOp<S, SD> where
    'o: 'static,
    S: LocalObservable<'o> + 'static,
    S::Unsub: 'static,
    SD: Scheduler, 

type Unsub = RcMultiSubscription

impl<'o, S, SD> LocalObservable<'o> for ObserveOnOp<S, SD> where
    'o: 'static,
    SD: Scheduler + 'static,
    S: LocalObservable<'o>, 

type Unsub = S::Unsub

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

type Unsub = RcMultiSubscription

impl<'o, S, SD> LocalObservable<'o> for ThrottleTimeOp<S, SD> where
    'o: 'static,
    S: LocalObservable<'o>,
    SD: Scheduler + 'static,
    S::Item: Clone + 'static, 

type Unsub = S::Unsub

impl<'o, Source, SD> LocalObservable<'o> for BufferWithCountOrTimerOp<Source, SD> where
    'o: 'static,
    Source: LocalObservable<'o>,
    Source::Item: 'static,
    SD: Scheduler + 'static, 

type Unsub = TimeSubscription<Rc<SpawnHandle>, Source::Unsub>

impl<'o, Source, SD> LocalObservable<'o> for BufferWithTimeOp<Source, SD> where
    'o: 'static,
    Source: LocalObservable<'o>,
    Source::Item: 'static,
    SD: Scheduler + 'static, 

type Unsub = TimeSubscription<Rc<SpawnHandle>, Source::Unsub>

impl<'o, Source, Sampling> LocalObservable<'o> for SampleOp<Source, Sampling> where
    Sampling::Item: 'o,
    Source: LocalObservable<'o>,
    Sampling: LocalObservable<'o, Err = Source::Err>,
    Source::Unsub: 'static,
    Sampling::Unsub: 'static, 

type Unsub = RcMultiSubscription

impl<'o, Src, Sbj> LocalObservable<'o> for RefCount<Rc<InnerRefCount<Src, Sbj, Src::Unsub>>> where
    ConnectableObservable<Src, Sbj>: Connect<Unsub = Src::Unsub>,
    Src: LocalObservable<'o> + 'o,
    Src::Unsub: Clone + 'o,
    Src::Item: Clone + 'o,
    Src::Err: Clone + 'o,
    Sbj: Observer<Item = Src::Item, Err = Src::Err> + TearDownSize + Clone + LocalObservable<'o, Item = Src::Item, Err = Src::Err> + 'o, 

type Unsub = RefCountSubscription<Sbj, Sbj::Unsub, Src::Unsub>

impl<'o, Src, Sbj> LocalObservable<'o> for ConnectableObservable<Src, Sbj> where
    Sbj: LocalObservable<'o>, 

type Unsub = Sbj::Unsub