[−][src]Struct rxrust::ops::map::MapOp
Trait Implementations
impl<S, B, M> Multicast for MapOp<S, M> where
S: Multicast,
M: RxFn(&S::Item) -> B + Send + Sync + 'static, [src]
S: Multicast,
M: RxFn(&S::Item) -> B + Send + Sync + 'static,
impl<S, B, M> Fork for MapOp<S, Arc<M>> where
S: Fork,
M: RxFn(&S::Item) -> B + Send + Sync + 'static, [src]
S: Fork,
M: RxFn(&S::Item) -> B + Send + Sync + 'static,
impl<S, B, M> RawSubscribable for MapOp<S, M> where
M: RxFn(&S::Item) -> B + Send + Sync + 'static,
S: RawSubscribable, [src]
M: RxFn(&S::Item) -> B + Send + Sync + 'static,
S: RawSubscribable,
Auto Trait Implementations
impl<S, M> Unpin for MapOp<S, M> where
M: Unpin,
S: Unpin,
M: Unpin,
S: Unpin,
impl<S, M> Sync for MapOp<S, M> where
M: Sync,
S: Sync,
M: Sync,
S: Sync,
impl<S, M> Send for MapOp<S, M> where
M: Send,
S: Send,
M: Send,
S: Send,
impl<S, M> UnwindSafe for MapOp<S, M> where
M: UnwindSafe,
S: UnwindSafe,
M: UnwindSafe,
S: UnwindSafe,
impl<S, M> RefUnwindSafe for MapOp<S, M> where
M: RefUnwindSafe,
S: RefUnwindSafe,
M: RefUnwindSafe,
S: RefUnwindSafe,
Blanket Implementations
impl<'a, O> Map<<O as RawSubscribable>::Item> for O where
O: RawSubscribable, [src]
O: RawSubscribable,
fn map<B, F>(self, f: F) -> MapOp<Self, RxFnWrapper<F>> where
Self: Sized,
F: Fn(&T) -> B, [src]
Self: Sized,
F: Fn(&T) -> B,
fn map_return_ref<B, F>(self, f: F) -> MapReturnRefOp<Self, RxFnWrapper<F>> where
Self: Sized,
F: for<'r> Fn(&'r T) -> &'r B, [src]
Self: Sized,
F: for<'r> Fn(&'r T) -> &'r B,
A version of map extension which return reference, and furthermore，return type and input item has same lifetime. Read more
impl<'a, T, O> Filter<T> for O where
O: RawSubscribable<Item = T>, [src]
O: RawSubscribable<Item = T>,
fn filter<N>(self, filter: N) -> FilterOp<Self, RxFnWrapper<N>> where
Self: Sized,
N: Fn(&T) -> bool, [src]
Self: Sized,
N: Fn(&T) -> bool,
impl<O> Merge for O where
O: RawSubscribable, [src]
O: RawSubscribable,
impl<'a, O> Take for O where
O: RawSubscribable, [src]
O: RawSubscribable,
impl<'a, O> First for O where
O: RawSubscribable, [src]
O: RawSubscribable,
impl<O> FirstOr for O where
O: RawSubscribable, [src]
O: RawSubscribable,
fn first_or(self, default: Self::Item) -> FirstOrOp<TakeOp<Self>, Self::Item> where
Self: RawSubscribable + Sized, [src]
Self: RawSubscribable + Sized,
impl<S> SubscribeOn for S where
S: RawSubscribable, [src]
S: RawSubscribable,
fn subscribe_on<SD>(self, scheduler: SD) -> SubscribeOnOP<Self, SD> where
Self: Sized, [src]
Self: Sized,
impl<S> ObserveOn for S where
S: RawSubscribable, [src]
S: RawSubscribable,
fn observe_on<SD>(self, scheduler: SD) -> ObserveOnOp<Self, SD> where
Self: Sized, [src]
Self: Sized,
impl<S> Delay for S where
S: RawSubscribable, [src]
S: RawSubscribable,
fn delay(self, dur: Duration) -> DelayOp<Self> where
Self: Sized, [src]
Self: Sized,
fn delay_at(self, at: Instant) -> DelayOp<Self> where
Self: Sized, [src]
Self: Sized,
impl<S> Subscribable for S where
S: RawSubscribable, [src]
S: RawSubscribable,
type Item = <S as RawSubscribable>::Item
type Err = <S as RawSubscribable>::Err
fn subscribe_all<impl Fn(&Self::Item) + Send + Sync + 'static, impl Fn(&Self::Err) + Send + Sync + 'static, impl Fn() + Send + Sync + 'static>(
Self,
impl Fn(&Self::Item) + Send + Sync + 'static,
impl Fn(&Self::Err) + Send + Sync + 'static,
impl Fn() + Send + Sync + 'static
) -> Box<dyn Subscription + 'static> where
impl Fn(&Self::Err) + Send + Sync + 'static: 'static + Send + Sync + Fn(&<S as Subscribable>::Err),
impl Fn(&Self::Item) + Send + Sync + 'static: 'static + Send + Sync + Fn(&<S as Subscribable>::Item),
impl Fn() + Send + Sync + 'static: 'static + Send + Sync + Fn(), [src]
Self,
impl Fn(&Self::Item) + Send + Sync + 'static,
impl Fn(&Self::Err) + Send + Sync + 'static,
impl Fn() + Send + Sync + 'static
) -> Box<dyn Subscription + 'static> where
impl Fn(&Self::Err) + Send + Sync + 'static: 'static + Send + Sync + Fn(&<S as Subscribable>::Err),
impl Fn(&Self::Item) + Send + Sync + 'static: 'static + Send + Sync + Fn(&<S as Subscribable>::Item),
impl Fn() + Send + Sync + 'static: 'static + Send + Sync + Fn(),
fn subscribe_err<impl Fn(&Self::Item) + Send + Sync + 'static, impl Fn(&Self::Err) + Send + Sync + 'static>(
Self,
impl Fn(&Self::Item) + Send + Sync + 'static,
impl Fn(&Self::Err) + Send + Sync + 'static
) -> Box<dyn Subscription + 'static> where
impl Fn(&Self::Err) + Send + Sync + 'static: 'static + Send + Sync + Fn(&<S as Subscribable>::Err),
impl Fn(&Self::Item) + Send + Sync + 'static: 'static + Send + Sync + Fn(&<S as Subscribable>::Item), [src]
Self,
impl Fn(&Self::Item) + Send + Sync + 'static,
impl Fn(&Self::Err) + Send + Sync + 'static
) -> Box<dyn Subscription + 'static> where
impl Fn(&Self::Err) + Send + Sync + 'static: 'static + Send + Sync + Fn(&<S as Subscribable>::Err),
impl Fn(&Self::Item) + Send + Sync + 'static: 'static + Send + Sync + Fn(&<S as Subscribable>::Item),
fn subscribe_complete<impl Fn(&Self::Item) + Send + Sync + 'static, impl Fn() + Send + Sync + 'static>(
Self,
impl Fn(&Self::Item) + Send + Sync + 'static,
impl Fn() + Send + Sync + 'static
) -> Box<dyn Subscription + 'static> where
impl Fn(&Self::Item) + Send + Sync + 'static: 'static + Send + Sync + Fn(&<S as Subscribable>::Item),
impl Fn() + Send + Sync + 'static: 'static + Send + Sync + Fn(), [src]
Self,
impl Fn(&Self::Item) + Send + Sync + 'static,
impl Fn() + Send + Sync + 'static
) -> Box<dyn Subscription + 'static> where
impl Fn(&Self::Item) + Send + Sync + 'static: 'static + Send + Sync + Fn(&<S as Subscribable>::Item),
impl Fn() + Send + Sync + 'static: 'static + Send + Sync + Fn(),
fn subscribe<impl Fn(&Self::Item) + Send + Sync + 'static>(
Self,
impl Fn(&Self::Item) + Send + Sync + 'static
) -> Box<dyn Subscription + 'static> where
impl Fn(&Self::Item) + Send + Sync + 'static: 'static + Send + Sync + Fn(&<S as Subscribable>::Item), [src]
Self,
impl Fn(&Self::Item) + Send + Sync + 'static
) -> Box<dyn Subscription + 'static> where
impl Fn(&Self::Item) + Send + Sync + 'static: 'static + Send + Sync + Fn(&<S as Subscribable>::Item),
fn into_subject(
Self
) -> Subject<<S as Subscribable>::Item, <S as Subscribable>::Err> where
<S as Subscribable>::Item: 'static,
<S as Subscribable>::Err: 'static, [src]
Self
) -> Subject<<S as Subscribable>::Item, <S as Subscribable>::Err> where
<S as Subscribable>::Item: 'static,
<S as Subscribable>::Err: 'static,
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T> From<T> for T[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T[src]
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,