Type Definition rxrust::subject::SharedSubject [−][src]
type SharedSubject<Item, Err> = Subject<Arc<Mutex<Vec<Box<dyn Publisher<Item = Item, Err = Err> + Send + Sync>>>>, SharedSubscription>;
Trait Implementations
impl<Item, Err> Observable for SharedSubject<Item, Err>
[src]
impl<Item, Err> Observable for SharedSubject<Item, Err>
[src]type Item = Item
type Err = Err
fn first(self) -> TakeOp<Self>
[src]
fn first_or(self, default: Self::Item) -> DefaultIfEmptyOp<TakeOp<Self>>
[src]
fn last_or(
self,
default: Self::Item
) -> DefaultIfEmptyOp<LastOp<Self, Self::Item>>
[src]
self,
default: Self::Item
) -> DefaultIfEmptyOp<LastOp<Self, Self::Item>>
fn element_at(self, nth: u32) -> TakeOp<SkipOp<Self>>
[src]
fn ignore_elements(self) -> FilterOp<Self, fn(_: &Self::Item) -> bool>
[src]
fn all<F>(
self,
pred: F
) -> DefaultIfEmptyOp<TakeOp<FilterOp<MapOp<Self, F>, fn(_: &bool) -> bool>>> where
F: Fn(Self::Item) -> bool,
[src]
self,
pred: F
) -> DefaultIfEmptyOp<TakeOp<FilterOp<MapOp<Self, F>, fn(_: &bool) -> bool>>> where
F: Fn(Self::Item) -> bool,
fn contains(self, target: Self::Item) -> ContainsOp<Self, Self::Item>
[src]
fn last(self) -> LastOp<Self, Self::Item>
[src]
fn finalize<F>(self, f: F) -> FinalizeOp<Self, F> where
F: FnMut(),
[src]
F: FnMut(),
fn flatten<Inner, A>(self) -> FlattenOp<Self, Inner> where
Inner: Observable<Item = A, Err = Self::Err>,
[src]
Inner: Observable<Item = A, Err = Self::Err>,
fn map<B, F>(self, f: F) -> MapOp<Self, F> where
F: Fn(Self::Item) -> B,
[src]
F: Fn(Self::Item) -> B,
fn map_to<B>(self, value: B) -> MapToOp<Self, B>
[src]
fn merge<S>(self, o: S) -> MergeOp<Self, S> where
S: Observable<Item = Self::Item, Err = Self::Err>,
[src]
S: Observable<Item = Self::Item, Err = Self::Err>,
fn filter<F>(self, filter: F) -> FilterOp<Self, F> where
F: Fn(&Self::Item) -> bool,
[src]
F: Fn(&Self::Item) -> bool,
fn filter_map<F, SourceItem, Item>(self, f: F) -> FilterMapOp<Self, F> where
F: FnMut(SourceItem) -> Option<Item>,
[src]
F: FnMut(SourceItem) -> Option<Item>,
fn box_it<O: IntoBox<Self>>(self) -> BoxOp<O> where
BoxOp<O>: Observable<Item = Self::Item, Err = Self::Err>,
[src]
BoxOp<O>: Observable<Item = Self::Item, Err = Self::Err>,
fn skip(self, count: u32) -> SkipOp<Self>
[src]
fn skip_while<F>(self, callback: F) -> SkipWhileOp<Self, F> where
F: FnMut(&Self::Item) -> bool,
[src]
F: FnMut(&Self::Item) -> bool,
fn skip_last(self, count: usize) -> SkipLastOp<Self>
[src]
fn take(self, count: u32) -> TakeOp<Self>
[src]
fn take_until<T>(self, notifier: T) -> TakeUntilOp<Self, T>
[src]
fn take_while<F>(self, callback: F) -> TakeWhileOp<Self, F> where
F: FnMut(&Self::Item) -> bool,
[src]
F: FnMut(&Self::Item) -> bool,
fn take_last(self, count: usize) -> TakeLastOp<Self>
[src]
fn sample<O>(self, sampling: O) -> SampleOp<Self, O> where
O: Observable,
[src]
O: Observable,
fn scan_initial<OutputItem, BinaryOp>(
self,
initial_value: OutputItem,
binary_op: BinaryOp
) -> ScanOp<Self, BinaryOp, OutputItem> where
BinaryOp: Fn(OutputItem, Self::Item) -> OutputItem,
OutputItem: Clone,
[src]
self,
initial_value: OutputItem,
binary_op: BinaryOp
) -> ScanOp<Self, BinaryOp, OutputItem> where
BinaryOp: Fn(OutputItem, Self::Item) -> OutputItem,
OutputItem: Clone,
fn scan<OutputItem, BinaryOp>(
self,
binary_op: BinaryOp
) -> ScanOp<Self, BinaryOp, OutputItem> where
BinaryOp: Fn(OutputItem, Self::Item) -> OutputItem,
OutputItem: Default + Clone,
[src]
self,
binary_op: BinaryOp
) -> ScanOp<Self, BinaryOp, OutputItem> where
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
BinaryOp: Fn(OutputItem, Self::Item) -> OutputItem,
OutputItem: Clone,
[src]
self,
initial: OutputItem,
binary_op: BinaryOp
) -> ReduceOp<Self, BinaryOp, OutputItem> where
BinaryOp: Fn(OutputItem, Self::Item) -> OutputItem,
OutputItem: Clone,
fn reduce<OutputItem, BinaryOp>(
self,
binary_op: BinaryOp
) -> DefaultIfEmptyOp<LastOp<ScanOp<Self, BinaryOp, OutputItem>, OutputItem>> where
BinaryOp: Fn(OutputItem, Self::Item) -> OutputItem,
OutputItem: Default + Clone,
[src]
self,
binary_op: BinaryOp
) -> DefaultIfEmptyOp<LastOp<ScanOp<Self, BinaryOp, OutputItem>, OutputItem>> where
BinaryOp: Fn(OutputItem, Self::Item) -> OutputItem,
OutputItem: Default + Clone,
fn max(self) -> MinMaxOp<Self, Self::Item> where
Self::Item: Clone + Send + PartialOrd<Self::Item>,
[src]
Self::Item: Clone + Send + PartialOrd<Self::Item>,
fn min(self) -> MinMaxOp<Self, Self::Item> where
Self::Item: Clone + Send + PartialOrd<Self::Item>,
[src]
Self::Item: Clone + Send + PartialOrd<Self::Item>,
fn sum(self) -> SumOp<Self, Self::Item> where
Self::Item: Clone + Default + Add<Self::Item, Output = Self::Item>,
[src]
Self::Item: Clone + Default + Add<Self::Item, Output = Self::Item>,
fn count(self) -> CountOp<Self, Self::Item>
[src]
fn average(self) -> AverageOp<Self, Self::Item> where
Self::Item: Clone + Send + Default + Add<Self::Item, Output = Self::Item> + Mul<f64, Output = Self::Item>,
[src]
Self::Item: Clone + Send + Default + Add<Self::Item, Output = Self::Item> + Mul<f64, Output = Self::Item>,
fn publish<Subject: Default>(self) -> ConnectableObservable<Self, Subject>
[src]
fn share<Subject, Inner>(
self
) -> RefCount<Inner, ConnectableObservable<Self, Subject>> where
Inner: RefCountCreator<Connectable = ConnectableObservable<Self, Subject>>,
Subject: Default,
Self: Clone,
[src]
self
) -> RefCount<Inner, ConnectableObservable<Self, Subject>> where
Inner: RefCountCreator<Connectable = ConnectableObservable<Self, Subject>>,
Subject: Default,
Self: Clone,
fn delay<SD>(self, dur: Duration, scheduler: SD) -> DelayOp<Self, SD>
[src]
fn delay_at<SD>(self, at: Instant, scheduler: SD) -> DelayOp<Self, SD>
[src]
fn subscribe_on<SD>(self, scheduler: SD) -> SubscribeOnOP<Self, SD>
[src]
fn observe_on<SD>(self, scheduler: SD) -> ObserveOnOp<Self, SD>
[src]
fn debounce<SD>(self, duration: Duration, scheduler: SD) -> DebounceOp<Self, SD>
[src]
fn throttle_time<SD>(
self,
duration: Duration,
edge: ThrottleEdge,
scheduler: SD
) -> ThrottleTimeOp<Self, SD>
[src]
self,
duration: Duration,
edge: ThrottleEdge,
scheduler: SD
) -> ThrottleTimeOp<Self, SD>
fn distinct(self) -> DistinctOp<Self>
[src]
fn zip<U>(self, other: U) -> ZipOp<Self, U> where
U: Observable,
[src]
U: Observable,
fn default_if_empty(self, default_value: Self::Item) -> DefaultIfEmptyOp<Self>
[src]
impl<Item, Err> SharedObservable for SharedSubject<Item, Err>
[src]
impl<Item, Err> SharedObservable for SharedSubject<Item, Err>
[src]type Unsub = SharedSubscription
fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Sync + Send + 'static>(
self,
subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub
[src]
self,
subscriber: Subscriber<O, SharedSubscription>
) -> Self::Unsub
fn into_shared(self) -> Shared<Self> where
Self: Sized,
[src]
Self: Sized,