Skip to main content

Pipe

rx_core

Struct Pipe 

Source 
pub struct Pipe<Source, Op>
where
    Source: Observable,
    Op: 'static + ComposableOperator<In = <Source as ObservableOutput>::Out, InError = <Source as ObservableOutput>::OutError>,
{ /* private fields */ }

Implementations§

Source§

impl<Source, Op> Pipe<Source, Op>
where Source: Observable, Op: 'static + ComposableOperator<In = <Source as ObservableOutput>::Out, InError = <Source as ObservableOutput>::OutError>,

Source

pub fn new(source_observable: Source, operator: Op) -> Pipe<Source, Op>

Trait Implementations§

Source§

impl<Source, Op> Clone for Pipe<Source, Op>
where Source: Clone + Observable, Op: Clone + 'static + ComposableOperator<In = <Source as ObservableOutput>::Out, InError = <Source as ObservableOutput>::OutError>,

Source§

fn clone(&self) -> Pipe<Source, Op>

Returns a duplicate of the value. Read more
1.0.0 · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl<Source, Op> Debug for Pipe<Source, Op>
where Source: Debug + Observable, Op: Debug + 'static + ComposableOperator<In = <Source as ObservableOutput>::Out, InError = <Source as ObservableOutput>::OutError>,

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter. Read more
Source§

impl<Source, Op> Observable for Pipe<Source, Op>
where Source: Observable, Op: 'static + ComposableOperator<In = <Source as ObservableOutput>::Out, InError = <Source as ObservableOutput>::OutError>,

Source§

type Subscription<Destination: 'static + Subscriber<In = <Pipe<Source, Op> as ObservableOutput>::Out, InError = <Pipe<Source, Op> as ObservableOutput>::OutError>> = <Source as Observable>::Subscription<<Op as ComposableOperator>::Subscriber<<Destination as UpgradeableObserver>::Upgraded>>

The subscription produced by this Observable. As this is the only kind of subscription that is handled directly by users, only here are subscriptions required to implement Drop to ensure resources are released when the subscription is dropped.
Source§

fn subscribe<Destination>( &mut self, observer: Destination, ) -> <Pipe<Source, Op> as Observable>::Subscription<<Destination as UpgradeableObserver>::Upgraded>
where Destination: 'static + UpgradeableObserver<In = <Pipe<Source, Op> as ObservableOutput>::Out, InError = <Pipe<Source, Op> as ObservableOutput>::OutError> + Send + Sync,

Create a Subscription for this Observable. This action allocates resources to execute the behavior this Observable defines, essentially creating an instance of it. Read more
Source§

impl<Source, Op> ObservableOutput for Pipe<Source, Op>
where Source: Observable, Op: 'static + ComposableOperator<In = <Source as ObservableOutput>::Out, InError = <Source as ObservableOutput>::OutError>,

Source§

type Out = <Op as ObservableOutput>::Out

Source§

type OutError = <Op as ObservableOutput>::OutError

Source§

impl<Source, Op> WithPrimaryCategory for Pipe<Source, Op>
where Source: Observable, Op: 'static + ComposableOperator<In = <Source as ObservableOutput>::Out, InError = <Source as ObservableOutput>::OutError>,

Source§

type PrimaryCategory = PrimaryCategoryObservable

Auto Trait Implementations§

§

impl<Source, Op> Freeze for Pipe<Source, Op>
where Source: Freeze, Op: Freeze,

§

impl<Source, Op> RefUnwindSafe for Pipe<Source, Op>
where Source: RefUnwindSafe, Op: RefUnwindSafe,

§

impl<Source, Op> Send for Pipe<Source, Op>
where Source: Send, Op: Send,

§

impl<Source, Op> Sync for Pipe<Source, Op>
where Source: Sync, Op: Sync,

§

impl<Source, Op> Unpin for Pipe<Source, Op>
where Source: Unpin, Op: Unpin,

§

impl<Source, Op> UnwindSafe for Pipe<Source, Op>
where Source: UnwindSafe, Op: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> Downcast for T
where T: Any,

Source§

fn into_any(self: Box<T>) -> Box<dyn Any>

Converts Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>, which can then be downcast into Box<dyn ConcreteType> where ConcreteType implements Trait.
Source§

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

Converts Rc<Trait> (where Trait: Downcast) to Rc<Any>, which can then be further downcast into Rc<ConcreteType> where ConcreteType implements Trait.
Source§

fn as_any(&self) -> &(dyn Any + 'static)

Converts &Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &Any’s vtable from &Trait’s.
Source§

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Converts &mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &mut Any’s vtable from &mut Trait’s.
Source§

impl<T> DowncastSend for T
where T: Any + Send,

Source§

fn into_any_send(self: Box<T>) -> Box<dyn Any + Send>

Converts Box<Trait> (where Trait: DowncastSend) to Box<dyn Any + Send>, which can then be downcast into Box<ConcreteType> where ConcreteType implements Trait.
Source§

impl<O> EraseObservableExtension<O> for O
where O: 'static + Observable + Send + Sync,

Source§

fn erase( self, ) -> ErasedObservable<<O as ObservableOutput>::Out, <O as ObservableOutput>::OutError>

Source§

impl<O> ErasedSubscribeObservableExtension<<O as ObservableOutput>::Out, <O as ObservableOutput>::OutError> for O
where O: 'static + Observable + Send + Sync,

Source§

fn erased_subscribe( &mut self, destination: Box<dyn Subscriber<In = <O as ObservableOutput>::Out, InError = <O as ObservableOutput>::OutError> + Send + Sync>, ) -> SubscriptionData

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> IntoResult<T> for T

Source§

fn into_result(self) -> Result<T, RunSystemError>

Converts this type into the system output type.
Source§

impl<'o, O> ObservablePipeExtensionAdsr<'o> for O
where O: 'o + Observable<Out = AdsrTrigger> + Send + Sync,

Source§

fn adsr<S>( self, options: AdsrOperatorOptions, scheduler: SchedulerHandle<S>, ) -> <AdsrOperator<Self::OutError, S> as Operator<'o>>::OutObservable<Self>
where S: Scheduler,

Source§

impl<'o, O> ObservablePipeExtensionBufferCount<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn buffer_count( self, buffer_size: usize, ) -> <BufferCountOperator<Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>

BufferCountOperator Read more
Source§

impl<'o, O> ObservablePipeExtensionCatch<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn catch<NextInnerObservable, OnError>( self, on_error: OnError, ) -> <CatchOperator<Self::Out, Self::OutError, OnError, NextInnerObservable> as Operator<'o>>::OutObservable<Self>
where NextInnerObservable: Observable<Out = Self::Out> + Signal, OnError: 'static + FnOnce(Self::OutError) -> NextInnerObservable + Clone + Send + Sync,

Source§

impl<'o, O> ObservablePipeExtensionConcatAll<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn concat_all<ErrorMapper>( self, error_mapper: ErrorMapper, ) -> <ConcatAllOperator<Self::Out, Self::OutError, ErrorMapper> as Operator<'o>>::OutObservable<Self>
where ErrorMapper: 'static + Fn(Self::OutError) -> <Self::Out as ObservableOutput>::OutError + Clone + Send + Sync, Self::Out: Observable, Self::OutError: Into<<Self::Out as ObservableOutput>::OutError>,

Source§

impl<'o, O> ObservablePipeExtensionConcatMap<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn concat_map<NextInnerObservable, Mapper, ErrorMapper>( self, mapper: Mapper, error_mapper: ErrorMapper, ) -> <ConcatMapOperator<Self::Out, Self::OutError, Mapper, ErrorMapper, NextInnerObservable> as Operator<'o>>::OutObservable<Self>
where NextInnerObservable: Observable + Signal, Mapper: 'static + Fn(Self::Out) -> NextInnerObservable + Clone + Send + Sync, ErrorMapper: 'static + FnOnce(Self::OutError) -> <NextInnerObservable as ObservableOutput>::OutError + Clone + Send + Sync, Self::OutError: Into<<NextInnerObservable as ObservableOutput>::OutError>,

Source§

impl<'o, O> ObservablePipeExtensionCount<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn count( self, ) -> <CountOperator<Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>

CountOperator Read more
Source§

impl<'o, O, T, S> ObservablePipeExtensionDebounceTime<'o, T, S> for O
where O: 'o + Observable<Out = T> + Send + Sync, T: Signal, S: 'static + Scheduler + Send + Sync,

Source§

fn debounce_time( self, duration: Duration, scheduler: SchedulerHandle<S>, ) -> <DebounceTimeOperator<T, Self::OutError, S> as Operator<'o>>::OutObservable<Self>

DebounceTimeOperator Read more
Source§

impl<'o, O, T, S> ObservablePipeExtensionDelay<'o, T, S> for O
where O: 'o + Observable<Out = T> + Send + Sync, T: Signal, S: 'static + Scheduler + Send + Sync,

Source§

fn delay( self, duration: Duration, scheduler: SchedulerHandle<S>, ) -> <DelayOperator<T, Self::OutError, S> as Operator<'o>>::OutObservable<Self>

DelayOperator Read more
Source§

impl<'o, O, In, InError> ObservablePipeExtensionDematerialize<'o, In, InError> for O
where O: 'o + Observable<Out = ObserverNotification<In, InError>, OutError = Infallible> + Send + Sync, In: Signal, InError: Signal,

Source§

fn dematerialize( self, ) -> <DematerializeOperator<In, InError> as Operator<'o>>::OutObservable<Self>

Source§

impl<'o, O> ObservablePipeExtensionElementAt<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn element_at( self, index: usize, ) -> <ElementAtOperator<Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>

ElementAtOperator Read more
Source§

fn element_at_or_else<P>( self, index: usize, default_value: P, ) -> <ElementAtOperator<Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>
where P: 'static + Provider<Provided = Self::Out> + Send + Sync,

ElementAtOperator Read more
Source§

impl<'o, O> ObservablePipeExtensionEndWith<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn end_with( self, end_with: Self::Out, ) -> <EndWithOperator<Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>
where Self::Out: Clone,

Source§

impl<'o, O> ObservablePipeExtensionEnumerate<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn enumerate( self, ) -> <EnumerateOperator<Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>

Source§

impl<'o, O> ObservablePipeExtensionErrorBoundary<'o> for O
where O: 'o + Observable<OutError = Infallible> + Send + Sync,

Source§

fn error_boundary( self, ) -> <ErrorBoundaryOperator<Self::Out> as Operator<'o>>::OutObservable<Self>

Source§

impl<'o, O> ObservablePipeExtensionExhaustAll<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn exhaust_all<ErrorMapper>( self, error_mapper: ErrorMapper, ) -> <ExhaustAllOperator<Self::Out, Self::OutError, ErrorMapper> as Operator<'o>>::OutObservable<Self>
where ErrorMapper: 'static + Fn(Self::OutError) -> <Self::Out as ObservableOutput>::OutError + Clone + Send + Sync, Self::Out: Observable, Self::OutError: Into<<Self::Out as ObservableOutput>::OutError>,

Source§

impl<'o, O> ObservablePipeExtensionExhaustMap<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn exhaust_map<NextInnerObservable, Mapper, ErrorMapper>( self, mapper: Mapper, error_mapper: ErrorMapper, ) -> <ExhaustMapOperator<Self::Out, Self::OutError, Mapper, ErrorMapper, NextInnerObservable> as Operator<'o>>::OutObservable<Self>
where NextInnerObservable: Observable + Signal, Mapper: 'static + FnMut(Self::Out) -> NextInnerObservable + Clone + Send + Sync, ErrorMapper: 'static + FnOnce(Self::OutError) -> <NextInnerObservable as ObservableOutput>::OutError + Clone + Send + Sync, Self::OutError: Into<<NextInnerObservable as ObservableOutput>::OutError>,

Source§

impl<'o, O> ObservablePipeExtensionFilter<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn filter<Filter>( self, filter: Filter, ) -> <FilterOperator<Self::Out, Self::OutError, Filter> as Operator<'o>>::OutObservable<Self>
where Filter: 'static + Fn(&Self::Out, usize) -> bool + Clone + Send + Sync,

Source§

impl<'o, O> ObservablePipeExtensionFilterMap<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn filter_map<NextOut, Mapper>( self, mapper: Mapper, ) -> <FilterMapOperator<Self::Out, Self::OutError, Mapper, NextOut> as Operator<'o>>::OutObservable<Self>
where NextOut: Signal, Mapper: 'static + Fn(Self::Out) -> Option<NextOut> + Clone + Send + Sync,

Source§

impl<'o, O> ObservablePipeExtensionFinalize<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn finalize<Callback>( self, teardown: Callback, ) -> <FinalizeOperator<Self::Out, Self::OutError, Callback> as Operator<'o>>::OutObservable<Self>
where Callback: 'static + Clone + FnOnce() + Send + Sync,

Source§

impl<'o, O> ObservablePipeExtensionFind<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn find<Predicate>( self, predicate: Predicate, ) -> <FindOperator<Self::Out, Self::OutError, Predicate> as Operator<'o>>::OutObservable<Self>
where Predicate: 'static + Fn(&Self::Out) -> bool + Clone + Send + Sync,

Source§

impl<'o, O> ObservablePipeExtensionFindIndex<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn find_index<P>( self, predicate: P, ) -> <FindIndexOperator<Self::Out, Self::OutError, P> as Operator<'o>>::OutObservable<Self>
where P: 'static + Fn(&Self::Out) -> bool + Clone + Send + Sync,

Source§

impl<'o, O> ObservablePipeExtensionFirst<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn first( self, ) -> <FirstOperator<Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>
where Self::Out: Clone,

Source§

impl<'o, O> ObservablePipeExtensionInto<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn fallback_when_silent<Fallback, S>( self, fallback: Fallback, scheduler: SchedulerHandle<S>, ) -> <FallbackWhenSilentOperator<Self::Out, Self::OutError, Fallback, S> as Operator<'o>>::OutObservable<Self>
where Fallback: 'static + Fn(<S as WithWorkInputOutput>::Tick, &mut <<S as WithWorkContextProvider>::WorkContextProvider as WorkContextProvider>::Item<'_>, usize) -> Self::Out + Clone + Send + Sync, S: 'static + Scheduler + Send + Sync,

Source§

impl<'o, O> ObservablePipeExtensionIsEmpty<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn is_empty( self, ) -> <IsEmptyOperator<Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>

IsEmptyOperator Read more
Source§

impl<'o, O, T> ObservablePipeExtensionLiftOption<'o, T> for O
where O: 'o + Observable<Out = Option<T>> + Send + Sync, T: Signal,

Source§

fn lift_option( self, ) -> <LiftOptionOperator<T, Self::OutError> as Operator<'o>>::OutObservable<Self>

Source§

impl<'o, O, ResultOut, ResultOutError> ObservablePipeExtensionLiftResult<'o, ResultOut, ResultOutError> for O
where O: 'o + Observable<Out = Result<ResultOut, ResultOutError>, OutError = Infallible> + Send + Sync, ResultOut: Signal, ResultOutError: Signal,

Source§

fn lift_result( self, ) -> <LiftResultOperator<ResultOut, ResultOutError, Self::OutError> as Operator<'o>>::OutObservable<Self>

Source§

impl<'o, O> ObservablePipeExtensionMap<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn map<NextOut, Mapper>( self, mapper: Mapper, ) -> <MapOperator<Self::Out, Self::OutError, Mapper, NextOut> as Operator<'o>>::OutObservable<Self>
where NextOut: Signal, Mapper: 'static + Fn(Self::Out) -> NextOut + Clone + Send + Sync,

Source§

impl<'o, O> ObservablePipeExtensionMapError<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn map_error<NextOutError, ErrorMapper>( self, error_mapper: ErrorMapper, ) -> <MapErrorOperator<Self::Out, Self::OutError, ErrorMapper, NextOutError> as Operator<'o>>::OutObservable<Self>
where NextOutError: Signal, ErrorMapper: 'static + FnOnce(Self::OutError) -> NextOutError + Clone + Send + Sync,

Source§

impl<'o, O> ObservablePipeExtensionMapInto<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn map_into<NextOut, NextOutError>( self, ) -> <MapIntoOperator<Self::Out, Self::OutError, NextOut, NextOutError> as Operator<'o>>::OutObservable<Self>
where NextOut: Signal, NextOutError: Signal, Self::Out: Into<NextOut>, Self::OutError: Into<NextOutError>,

Source§

impl<'o, O> ObservablePipeExtensionMapNeverBoth<'o> for O
where O: Observable<Out = Infallible, OutError = Infallible> + 'o + Send + Sync,

Source§

fn map_never_both<NextOut, NextOutError>( self, ) -> <MapNeverBothOperator<NextOut, NextOutError> as Operator<'o>>::OutObservable<Self>
where NextOut: Signal, NextOutError: Signal,

Source§

impl<'o, O> ObservablePipeExtensionMapNeverError<'o> for O
where O: 'o + Observable<OutError = Infallible> + Send + Sync,

Source§

fn map_never<NextOutError>( self, ) -> <MapNeverErrorOperator<Self::Out, NextOutError> as Operator<'o>>::OutObservable<Self>
where NextOutError: Signal,

Source§

impl<'o, O> ObservablePipeExtensionMapNeverNext<'o> for O
where O: 'o + Observable<Out = Infallible> + Send + Sync,

Source§

fn map_never<NextOut>( self, ) -> <MapNeverNextOperator<NextOut, Self::OutError> as Operator<'o>>::OutObservable<Self>
where NextOut: Signal,

Source§

impl<'o, O> ObservablePipeExtensionMaterialize<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn materialize( self, ) -> <MaterializeOperator<Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>

Source§

impl<'o, O> ObservablePipeExtensionMergeAll<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn merge_all<ErrorMapper>( self, concurrency_limit: usize, error_mapper: ErrorMapper, ) -> <MergeAllOperator<Self::Out, Self::OutError, ErrorMapper> as Operator<'o>>::OutObservable<Self>
where ErrorMapper: 'static + Fn(Self::OutError) -> <Self::Out as ObservableOutput>::OutError + Clone + Send + Sync, Self::Out: Observable, Self::OutError: Into<<Self::Out as ObservableOutput>::OutError>,

Source§

impl<'o, O> ObservablePipeExtensionMergeMap<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn merge_map<NextInnerObservable, Mapper, ErrorMapper>( self, mapper: Mapper, concurrency_limit: usize, error_mapper: ErrorMapper, ) -> <MergeMapOperator<Self::Out, Self::OutError, Mapper, ErrorMapper, NextInnerObservable> as Operator<'o>>::OutObservable<Self>
where NextInnerObservable: Observable + Signal, Mapper: 'static + Fn(Self::Out) -> NextInnerObservable + Clone + Send + Sync, ErrorMapper: 'static + FnOnce(Self::OutError) -> <NextInnerObservable as ObservableOutput>::OutError + Clone + Send + Sync, Self::OutError: Into<<NextInnerObservable as ObservableOutput>::OutError>,

Source§

impl<'o, O, T, S> ObservablePipeExtensionObserveOn<'o, T, S> for O
where O: 'o + Observable<Out = T> + Send + Sync, T: Signal, S: 'static + Scheduler + Send + Sync,

Source§

fn observe_on( self, scheduler: SchedulerHandle<S>, ) -> <ObserveOnOperator<T, Self::OutError, S> as Operator<'o>>::OutObservable<Self>

ObserveOnOperator Read more
Source§

impl<'o, O> ObservablePipeExtensionOnNext<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn on_next<OnNext>( self, on_next: OnNext, ) -> <OnNextOperator<OnNext, Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>
where OnNext: 'static + FnMut(&Self::Out, &mut dyn Subscriber<In = Self::Out, InError = Self::OutError>) -> bool + Send + Sync + Clone,

Source§

impl<'o, O> ObservablePipeExtensionOnSubscribe<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn on_subscribe<OnSubscribe>( self, on_subscribe: OnSubscribe, ) -> <OnSubscribeOperator<OnSubscribe, Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>
where OnSubscribe: 'static + FnMut(&mut dyn Subscriber<In = Self::Out, InError = Self::OutError>) + Send + Sync,

Source§

impl<'o, O> ObservablePipeExtensionPairwise<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn pairwise( self, ) -> <PairwiseOperator<Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>
where Self::Out: Clone,

PairwiseOperator Read more
Source§

impl<O> ObservablePipeExtensionPipe for O
where O: Observable + Send + Sync,

Source§

fn pipe<'o, Op>(self, operator: Op) -> <Op as Operator<'o>>::OutObservable<Self>
where Self: Sized, Op: Operator<'o, In = Self::Out, InError = Self::OutError>,

Source§

impl<'o, O> ObservablePipeExtensionReduce<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn reduce<NextOut, Reducer>( self, reducer: Reducer, seed: NextOut, ) -> <ReduceOperator<Self::Out, Self::OutError, Reducer, NextOut> as Operator<'o>>::OutObservable<Self>
where NextOut: Signal + Clone, Reducer: 'static + Fn(&NextOut, Self::Out) -> NextOut + Clone + Send + Sync,

Source§

impl<'o, O> ObservablePipeExtensionRetry<'o> for O
where 'o: 'static, O: 'o + Observable + Send + Sync,

Source§

fn retry( self, max_retries: usize, ) -> <RetryOperator<Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>

Source§

impl<'o, O> ObservablePipeExtensionScan<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn scan<NextOut, Reducer>( self, reducer: Reducer, seed: NextOut, ) -> <ScanOperator<Self::Out, Self::OutError, Reducer, NextOut> as Operator<'o>>::OutObservable<Self>
where NextOut: Signal + Clone, Reducer: 'static + Fn(&NextOut, Self::Out) -> NextOut + Clone + Send + Sync,

Source§

impl<'o, O> ObservablePipeExtensionShare<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn share<ConnectorProvider>( self, options: ConnectableOptions<ConnectorProvider>, ) -> <ShareOperator<ConnectorProvider> as Operator<'o>>::OutObservable<Self>
where Self::Out: Clone, Self::OutError: Clone, ConnectorProvider: 'static + Provider, <ConnectorProvider as Provider>::Provided: SubjectLike<In = Self::Out, InError = Self::OutError> + Clone,

Source§

impl<'o, O> ObservablePipeExtensionSkip<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn skip( self, count: usize, ) -> <SkipOperator<Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>

Source§

impl<'o, O> ObservablePipeExtensionStartWith<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn start_with( self, start_with: Self::Out, ) -> <StartWithOperator<Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>
where Self::Out: Clone,

Source§

impl<'o, O, T, S> ObservablePipeExtensionSubscribeOn<'o, T, S> for O
where 'o: 'static, O: 'o + Observable<Out = T> + Send + Sync, T: Signal, S: 'static + Scheduler + Send + Sync,

Source§

fn subscribe_on_with_delay( self, delay: Duration, scheduler: SchedulerHandle<S>, ) -> <SubscribeOnOperator<T, Self::OutError, S> as Operator<'o>>::OutObservable<Self>

SubscribeOnOperator Read more
Source§

fn subscribe_on( self, scheduler: SchedulerHandle<S>, ) -> <SubscribeOnOperator<T, Self::OutError, S> as Operator<'o>>::OutObservable<Self>

SubscribeOnOperator Read more
Source§

impl<'o, O> ObservablePipeExtensionSwitchAll<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn switch_all<ErrorMapper>( self, error_mapper: ErrorMapper, ) -> <SwitchAllOperator<Self::Out, Self::OutError, ErrorMapper> as Operator<'o>>::OutObservable<Self>
where ErrorMapper: 'static + Fn(Self::OutError) -> <Self::Out as ObservableOutput>::OutError + Clone + Send + Sync, Self::Out: Observable, Self::OutError: Into<<Self::Out as ObservableOutput>::OutError>,

Source§

impl<'o, O> ObservablePipeExtensionSwitchMap<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn switch_map<NextInnerObservable, Mapper, ErrorMapper>( self, mapper: Mapper, error_mapper: ErrorMapper, ) -> <SwitchMapOperator<Self::Out, Self::OutError, Mapper, ErrorMapper, NextInnerObservable> as Operator<'o>>::OutObservable<Self>
where NextInnerObservable: Observable + Signal, Mapper: 'static + FnMut(Self::Out) -> NextInnerObservable + Clone + Send + Sync, ErrorMapper: 'static + FnOnce(Self::OutError) -> <NextInnerObservable as ObservableOutput>::OutError + Clone + Send + Sync, Self::OutError: Into<<NextInnerObservable as ObservableOutput>::OutError>,

switch_map Read more
Source§

impl<'o, O> ObservablePipeExtensionTake<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn take( self, count: usize, ) -> <TakeOperator<Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>

Source§

impl<'o, O> ObservablePipeExtensionTap<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn tap<TapDestination>( self, tap_destination: TapDestination, ) -> <TapOperator<TapDestination> as Operator<'o>>::OutObservable<Self>
where TapDestination: 'static + RxObserver<In = Self::Out, InError = Self::OutError> + Clone + Send + Sync, Self::Out: Clone, Self::OutError: Clone,

Source§

impl<'o, O> ObservablePipeExtensionTapNext<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn tap_next<OnNext>( self, callback: OnNext, ) -> <TapNextOperator<Self::Out, Self::OutError, OnNext> as Operator<'o>>::OutObservable<Self>
where OnNext: 'static + FnMut(&Self::Out) + Clone + Send + Sync,

Source§

impl<'o, O, T, S> ObservablePipeExtensionThrottleTime<'o, T, S> for O
where O: 'o + Observable<Out = T> + Send + Sync, T: Signal, S: 'static + Scheduler + Send + Sync,

Source§

fn throttle_time( self, options: ThrottleTimeOptions, scheduler: SchedulerHandle<S>, ) -> <ThrottleTimeOperator<T, Self::OutError, S> as Operator<'o>>::OutObservable<Self>

ThrottleTimeOperator Read more
Source§

impl<'o, O> ObservablePipeExtensionTryCapture<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn into_result( self, ) -> <IntoResultOperator<Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>

IntoResultOperator Read more
Source§

impl<'o, O> ObservablePipeExtensionWithLatestFrom<'o> for O
where O: 'o + Observable + Send + Sync,

Source§

fn with_latest_from<InnerObservable>( self, inner_observable: InnerObservable, ) -> <WithLatestFromOperator<InnerObservable, Self::Out, Self::OutError> as Operator<'o>>::OutObservable<Self>
where InnerObservable: 'static + Observable<OutError = Self::OutError>, <InnerObservable as ObservableOutput>::Out: Clone,

WithLatestFromOperator Read more
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> ConditionalSend for T
where T: Send,

Source§

impl<T> Signal for T
where T: 'static + Send + Sync,