[−][src]Type Definition rxrust::prelude::LocalSubject
type LocalSubject<'a, Item, Err> = Subject<Rc<RefCell<Vec<Box<dyn Publisher<Item, Err> + 'a>>>>, LocalSubscription>;
Trait Implementations
impl<'a, Item, Err> LocalObservable<'a> for LocalSubject<'a, Item, Err>
[src]
type Unsub = LocalSubscription
fn actual_subscribe<O: Observer<Self::Item, Self::Err> + 'a>(
self,
subscriber: Subscriber<O, LocalSubscription>
) -> LocalSubscription
[src]
self,
subscriber: Subscriber<O, LocalSubscription>
) -> LocalSubscription
impl<'a, Item, Err> Observable for LocalSubject<'a, Item, Err>
[src]
type Item = Item
type Err = Err
fn first(self) -> TakeOp<Self> where
Self: Sized,
[src]
Self: Sized,
fn first_or(self, default: Self::Item) -> FirstOrOp<TakeOp<Self>, Self::Item> where
Self: Sized,
[src]
Self: Sized,
fn last_or(self, default: Self::Item) -> LastOrOp<Self, Self::Item> where
Self: Sized,
[src]
Self: Sized,
fn last(self) -> LastOrOp<Self, Self::Item> where
Self: Sized,
[src]
Self: Sized,
fn finalize<F>(self, f: F) -> FinalizeOp<Self, F> where
Self: Sized,
F: FnMut(),
[src]
Self: Sized,
F: FnMut(),
fn map<B, F>(self, f: F) -> MapOp<Self, F> where
Self: Sized,
F: Fn(Self::Item) -> B,
[src]
Self: Sized,
F: Fn(Self::Item) -> B,
fn map_to<B>(self, value: B) -> MapToOp<Self, B> where
Self: Sized,
[src]
Self: Sized,
fn merge<S>(self, o: S) -> MergeOp<Self, S> where
Self: Sized,
S: Observable<Item = Self::Item, Err = Self::Err>,
[src]
Self: Sized,
S: Observable<Item = Self::Item, Err = Self::Err>,
fn filter<F>(self, filter: F) -> FilterOp<Self, F> where
Self: Sized,
F: Fn(&Self::Item) -> bool,
[src]
Self: Sized,
F: Fn(&Self::Item) -> bool,
fn filter_map<F, SourceItem, Item>(self, f: F) -> FilterMapOp<Self, F> where
Self: Sized,
F: FnMut(SourceItem) -> Option<Item>,
[src]
Self: Sized,
F: FnMut(SourceItem) -> Option<Item>,
fn box_it<O: IntoBox<Self>>(self) -> BoxOp<O> where
Self: Sized,
BoxOp<O>: Observable<Item = Self::Item, Err = Self::Err>,
[src]
Self: Sized,
BoxOp<O>: Observable<Item = Self::Item, Err = Self::Err>,
fn skip(self, count: u32) -> SkipOp<Self> where
Self: Sized,
[src]
Self: Sized,
fn skip_last(self, count: usize) -> SkipLastOp<Self> where
Self: Sized,
[src]
Self: Sized,
fn take(self, count: u32) -> TakeOp<Self> where
Self: Sized,
[src]
Self: Sized,
fn take_until<T>(self, notifier: T) -> TakeUntilOp<Self, T> where
Self: Sized,
[src]
Self: Sized,
fn take_while<F>(self, callback: F) -> TakeWhileOp<Self, F> where
Self: Sized,
F: FnMut(&Self::Item) -> bool,
[src]
Self: Sized,
F: FnMut(&Self::Item) -> bool,
fn take_last(self, count: usize) -> TakeLastOp<Self> where
Self: Sized,
[src]
Self: Sized,
fn sample<O>(self, sampling: O) -> SampleOp<Self, O> where
Self: Sized,
O: Observable,
[src]
Self: Sized,
O: Observable,
fn scan_initial<OutputItem, BinaryOp>(
self,
initial_value: OutputItem,
binary_op: BinaryOp
) -> ScanOp<Self, BinaryOp, OutputItem> where
Self: Sized,
BinaryOp: Fn(OutputItem, Self::Item) -> OutputItem,
OutputItem: Clone,
[src]
self,
initial_value: OutputItem,
binary_op: BinaryOp
) -> ScanOp<Self, BinaryOp, OutputItem> where
Self: Sized,
BinaryOp: Fn(OutputItem, Self::Item) -> OutputItem,
OutputItem: Clone,
fn scan<OutputItem, BinaryOp>(
self,
binary_op: BinaryOp
) -> ScanOp<Self, BinaryOp, OutputItem> where
Self: Sized,
BinaryOp: Fn(OutputItem, Self::Item) -> OutputItem,
OutputItem: Default + Clone,
[src]
self,
binary_op: BinaryOp
) -> ScanOp<Self, BinaryOp, OutputItem> where
Self: Sized,
BinaryOp: Fn(OutputItem, Self::Item) -> OutputItem,
OutputItem: Default + Clone,
fn reduce_initial<OutputItem, BinaryOp>(
self,
initial: OutputItem,
binary_op: BinaryOp
) -> ReduceOp<Self, BinaryOp, OutputItem> where
Self: Sized,
BinaryOp: Fn(OutputItem, Self::Item) -> OutputItem,
OutputItem: Clone,
[src]
self,
initial: OutputItem,
binary_op: BinaryOp
) -> ReduceOp<Self, BinaryOp, OutputItem> where
Self: Sized,
BinaryOp: Fn(OutputItem, Self::Item) -> OutputItem,
OutputItem: Clone,
fn reduce<OutputItem, BinaryOp>(
self,
binary_op: BinaryOp
) -> LastOrOp<ScanOp<Self, BinaryOp, OutputItem>, OutputItem> where
Self: Sized,
BinaryOp: Fn(OutputItem, Self::Item) -> OutputItem,
OutputItem: Default + Clone,
[src]
self,
binary_op: BinaryOp
) -> LastOrOp<ScanOp<Self, BinaryOp, OutputItem>, OutputItem> where
Self: Sized,
BinaryOp: Fn(OutputItem, Self::Item) -> OutputItem,
OutputItem: Default + Clone,
fn max(self) -> MinMaxOp<Self, Self::Item> where
Self: Sized,
Self::Item: Clone + Send + PartialOrd<Self::Item>,
[src]
Self: Sized,
Self::Item: Clone + Send + PartialOrd<Self::Item>,
fn min(self) -> MinMaxOp<Self, Self::Item> where
Self: Sized,
Self::Item: Clone + Send + PartialOrd<Self::Item>,
[src]
Self: Sized,
Self::Item: Clone + Send + PartialOrd<Self::Item>,
fn sum(self) -> SumOp<Self, Self::Item> where
Self: Sized,
Self::Item: Clone + Default + Add<Self::Item, Output = Self::Item>,
[src]
Self: Sized,
Self::Item: Clone + Default + Add<Self::Item, Output = Self::Item>,
fn count(self) -> CountOp<Self, Self::Item> where
Self: Sized,
[src]
Self: Sized,
fn average(self) -> AverageOp<Self, Self::Item> where
Self: Sized,
Self::Item: Clone + Send + Default + Add<Self::Item, Output = Self::Item> + Mul<f64, Output = Self::Item>,
[src]
Self: Sized,
Self::Item: Clone + Send + Default + Add<Self::Item, Output = Self::Item> + Mul<f64, Output = Self::Item>,
fn publish<Subject: Default>(self) -> ConnectableObservable<Self, Subject> where
Self: Sized,
[src]
Self: Sized,
fn share<Subject, Inner>(
self
) -> RefCount<Inner, ConnectableObservable<Self, Subject>> where
Inner: RefCountCreator<Connectable = ConnectableObservable<Self, Subject>>,
Subject: Default,
Self: Sized + Clone,
[src]
self
) -> RefCount<Inner, ConnectableObservable<Self, Subject>> where
Inner: RefCountCreator<Connectable = ConnectableObservable<Self, Subject>>,
Subject: Default,
Self: Sized + Clone,
fn delay<SD>(self, dur: Duration, scheduler: SD) -> DelayOp<Self, SD> where
Self: Sized,
[src]
Self: Sized,
fn delay_at<SD>(self, at: Instant, scheduler: SD) -> DelayOp<Self, SD> where
Self: Sized,
[src]
Self: Sized,
fn subscribe_on<SD>(self, scheduler: SD) -> SubscribeOnOP<Self, SD> where
Self: Sized,
[src]
Self: Sized,
fn observe_on<SD>(self, scheduler: SD) -> ObserveOnOp<Self, SD> where
Self: Sized,
[src]
Self: Sized,
fn throttle_time<SD>(
self,
duration: Duration,
edge: ThrottleEdge,
scheduler: SD
) -> ThrottleTimeOp<Self, SD> where
Self: Sized,
[src]
self,
duration: Duration,
edge: ThrottleEdge,
scheduler: SD
) -> ThrottleTimeOp<Self, SD> where
Self: Sized,
fn zip<U>(self, other: U) -> ZipOp<Self, U> where
Self: Sized,
U: Observable,
[src]
Self: Sized,
U: Observable,
fn default_if_empty(self, default_value: Self::Item) -> DefaultIfEmptyOp<Self> where
Self: Sized,
[src]
Self: Sized,