Trait Operator 

pub trait Operator<'o>: ObserverInput + ObservableOutput {
    type OutObservable<InObservable: 'o + Observable<Out = Self::In, OutError = Self::InError> + Send + Sync>: 'o + Observable<Out = Self::Out, OutError = Self::OutError>;

    // Required method
    fn operate<InObservable>(
        self,
        source: InObservable,
    ) -> Self::OutObservable<InObservable>
       where InObservable: 'o + Observable<Out = Self::In, OutError = Self::InError> + Send + Sync;
}

Operator

Operators transform Observables, giving them new behavior.

Composable Operators

Operators who just want to wrap the destination in a subscriber can also implement ComposableOperator instead. Which allows the operator to be composable in addition.

Required Associated Types

type OutObservable<InObservable: 'o + Observable<Out = Self::In, OutError = Self::InError> + Send + Sync>: 'o + Observable<Out = Self::Out, OutError = Self::OutError>

Required Methods

fn operate<InObservable>( self, source: InObservable, ) -> Self::OutObservable<InObservable>

where InObservable: 'o + Observable<Out = Self::In, OutError = Self::InError> + Send + Sync,

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<'o, ConnectorProvider> Operator<'o> for ShareOperator<ConnectorProvider>

where ConnectorProvider: 'static + Provider, <ConnectorProvider as Provider>::Provided: SubjectLike + Clone, <ShareOperator<ConnectorProvider> as ObserverInput>::In: Clone, <ShareOperator<ConnectorProvider> as ObserverInput>::InError: Clone,

type OutObservable<InObservable: 'o + Observable<Out = <ShareOperator<ConnectorProvider> as ObserverInput>::In, OutError = <ShareOperator<ConnectorProvider> as ObserverInput>::InError> + Send + Sync> = ShareObservable<InObservable, ConnectorProvider>

impl<'o, In, InError> Operator<'o> for RetryOperator<In, InError>

where 'o: 'static, In: Signal, InError: Signal,

type OutObservable<InObservable: 'o + Observable<Out = <RetryOperator<In, InError> as ObserverInput>::In, OutError = <RetryOperator<In, InError> as ObserverInput>::InError> + Send + Sync> = RetryObservable<'o, InObservable>

impl<'o, In, InError, S> Operator<'o> for SubscribeOnOperator<In, InError, S>

where 'o: 'static, In: Signal, InError: Signal, S: 'static + Scheduler + Send + Sync,

type OutObservable<InObservable: 'o + Observable<Out = <SubscribeOnOperator<In, InError, S> as ObserverInput>::In, OutError = <SubscribeOnOperator<In, InError, S> as ObserverInput>::InError> + Send + Sync> = SubscribeOnObservable<InObservable, S>

impl<'o, Op> Operator<'o> for Op

where Op: 'static + ComposableOperator,

type OutObservable<InObservable: 'o + Observable<Out = <Op as ObserverInput>::In, OutError = <Op as ObserverInput>::InError> + Send + Sync> = Pipe<InObservable, Op>