Trait ObserverInput 

pub trait ObserverInput {
    type In: Signal;
    type InError: Signal;
}

Required Associated Types

type In: Signal

type InError: Signal

Implementations on Foreign Types

impl<Destination> ObserverInput for Arc<Mutex<Destination>>

where Destination: ObserverInput + ?Sized,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<Destination> ObserverInput for Arc<RwLock<Destination>>

where Destination: ObserverInput + ?Sized,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<Destination> ObserverInput for Weak<Mutex<Destination>>

where Destination: ObserverInput + ?Sized,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<Destination> ObserverInput for DematerializeSubscriber<Destination>

where Destination: Subscriber,

type In = ObserverNotification<<Destination as ObserverInput>::In, <Destination as ObserverInput>::InError>

type InError = Infallible

impl<Destination> ObserverInput for EndWithSubscriber<Destination>

where Destination: Subscriber,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<Destination> ObserverInput for ErrorBoundarySubscriber<Destination>

where Destination: Subscriber<InError = Infallible>,

type In = <Destination as ObserverInput>::In

type InError = Infallible

impl<Destination> ObserverInput for IdentitySubscriber<Destination>

where Destination: Subscriber,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<Destination> ObserverInput for LiftOptionSubscriber<Destination>

where Destination: Subscriber,

type In = Option<<Destination as ObserverInput>::In>

type InError = <Destination as ObserverInput>::InError

impl<Destination> ObserverInput for MapNeverBothSubscriber<Destination>

where Destination: Subscriber,

type In = Infallible

type InError = Infallible

impl<Destination> ObserverInput for MapNeverErrorSubscriber<Destination>

where Destination: Subscriber,

type In = <Destination as ObserverInput>::In

type InError = Infallible

impl<Destination> ObserverInput for MapNeverNextSubscriber<Destination>

where Destination: Subscriber,

type In = Infallible

type InError = <Destination as ObserverInput>::InError

impl<Destination> ObserverInput for SkipSubscriber<Destination>

where Destination: Subscriber,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<Destination> ObserverInput for TakeSubscriber<Destination>

where Destination: Subscriber,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<Destination, O1, O2> ObserverInput for CombineChangesSubscriber<Destination, O1, O2>

where Destination: Subscriber<In = (Change<<O1 as ObservableOutput>::Out>, Change<<O2 as ObservableOutput>::Out>)>, O1: 'static + Observable, <O1 as ObservableOutput>::Out: Clone, <O1 as ObservableOutput>::OutError: Into<<Destination as ObserverInput>::InError>, O2: 'static + Observable, <O2 as ObservableOutput>::Out: Clone, <O2 as ObservableOutput>::OutError: Into<<Destination as ObserverInput>::InError>,

type In = EitherObservableNotification2<O1, O2>

type InError = <Destination as ObserverInput>::InError

impl<Destination, O1, O2> ObserverInput for CombineLatestSubscriber<Destination, O1, O2>

where Destination: Subscriber<In = (<O1 as ObservableOutput>::Out, <O2 as ObservableOutput>::Out)>, O1: 'static + Observable, <O1 as ObservableOutput>::Out: Clone, <O1 as ObservableOutput>::OutError: Into<<Destination as ObserverInput>::InError>, O2: 'static + Observable, <O2 as ObservableOutput>::Out: Clone, <O2 as ObservableOutput>::OutError: Into<<Destination as ObserverInput>::InError>,

type In = EitherObservableNotification2<O1, O2>

type InError = <Destination as ObserverInput>::InError

impl<Destination, O1, O2> ObserverInput for JoinSubscriber<Destination, O1, O2>

where Destination: Subscriber<In = (<O1 as ObservableOutput>::Out, <O2 as ObservableOutput>::Out)>, O1: 'static + Observable, <O1 as ObservableOutput>::Out: Clone, <O1 as ObservableOutput>::OutError: Into<<Destination as ObserverInput>::InError>, O2: 'static + Observable, <O2 as ObservableOutput>::Out: Clone, <O2 as ObservableOutput>::OutError: Into<<Destination as ObserverInput>::InError>,

type In = EitherObservableNotification2<O1, O2>

type InError = <Destination as ObserverInput>::InError

impl<Destination, O1, O2> ObserverInput for ZipSubscriber<Destination, O1, O2>

where Destination: Subscriber<In = (<O1 as ObservableOutput>::Out, <O2 as ObservableOutput>::Out)>, O1: 'static + Observable, <O1 as ObservableOutput>::Out: Clone, <O1 as ObservableOutput>::OutError: Into<<Destination as ObserverInput>::InError>, O2: 'static + Observable, <O2 as ObservableOutput>::Out: Clone, <O2 as ObservableOutput>::OutError: Into<<Destination as ObserverInput>::InError>,

type In = EitherObservableNotification2<O1, O2>

type InError = <Destination as ObserverInput>::InError

impl<Destination, S> ObserverInput for DebounceTimeSubscriber<Destination, S>

where Destination: 'static + Subscriber, S: 'static + Scheduler,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<Destination, S> ObserverInput for DelaySubscriber<Destination, S>

where Destination: 'static + Subscriber, S: 'static + Scheduler,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<Destination, S> ObserverInput for ObserveOnSubscriber<Destination, S>

where Destination: 'static + Subscriber, S: 'static + Scheduler,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<Destination, S> ObserverInput for ThrottleTimeSubscriber<Destination, S>

where Destination: 'static + Subscriber, S: 'static + Scheduler,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<Filter, Destination> ObserverInput for FilterSubscriber<Filter, Destination>

where Filter: for<'a> Fn(&'a <Destination as ObserverInput>::In, usize) -> bool, Destination: Subscriber,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<In, Destination> ObserverInput for BufferCountSubscriber<In, Destination>

where In: Signal, Destination: Subscriber<In = Vec<In>>,

type In = In

type InError = <Destination as ObserverInput>::InError

impl<In, Destination> ObserverInput for EnumerateSubscriber<In, Destination>

where In: Signal, Destination: Subscriber<In = (In, usize)>,

type In = In

type InError = <Destination as ObserverInput>::InError

impl<In, Destination> ObserverInput for IsEmptySubscriber<In, Destination>

where In: Signal, Destination: Subscriber<In = bool>,

type In = In

type InError = <Destination as ObserverInput>::InError

impl<In, Destination> ObserverInput for PairwiseSubscriber<In, Destination>

where In: Signal + Clone, Destination: Subscriber<In = [In; 2]>,

type In = In

type InError = <Destination as ObserverInput>::InError

impl<In, ErrorDestination> ObserverInput for WithLatestFromInnerDestination<In, ErrorDestination>

where In: Signal, ErrorDestination: 'static + Subscriber,

type In = In

type InError = <ErrorDestination as ObserverInput>::InError

impl<In, InError, Destination> ObserverInput for CountSubscriber<In, InError, Destination>

where In: Signal, InError: Signal, Destination: Subscriber<In = usize, InError = InError>,

type In = In

type InError = InError

impl<In, InError, Destination> ObserverInput for ElementAtSubscriber<In, InError, Destination>

where In: Signal, InError: Signal, Destination: Subscriber<In = In, InError = ElementAtOperatorError<InError>>,

type In = In

type InError = InError

impl<In, InError, Destination> ObserverInput for IntoResultSubscriber<In, InError, Destination>

where In: Signal, InError: Signal, Destination: Subscriber<In = Result<In, InError>>,

type In = In

type InError = InError

impl<In, InError, Destination> ObserverInput for MaterializeSubscriber<In, InError, Destination>

where In: Signal, InError: Signal, Destination: Subscriber<In = ObserverNotification<In, InError>, InError = Infallible>,

type In = In

type InError = InError

impl<In, InError, ErrorMapper, OutError, Destination> ObserverInput for MapErrorSubscriber<In, InError, ErrorMapper, OutError, Destination>

where In: Signal, InError: Signal, ErrorMapper: FnOnce(InError) -> OutError + Send + Sync, OutError: Signal, Destination: Subscriber<In = In, InError = OutError>,

type In = In

type InError = InError

impl<In, InError, Fallback, Destination, S> ObserverInput for FallbackWhenSilentSubscriber<In, InError, Fallback, Destination, S>

where In: Signal, InError: Signal, Fallback: 'static + Fn(<S as WithWorkInputOutput>::Tick, &mut <<S as WithWorkContextProvider>::WorkContextProvider as WorkContextProvider>::Item<'_>, usize) -> In + Send + Sync, Destination: 'static + Subscriber<In = In, InError = InError>, S: Scheduler,

type In = In

type InError = InError

impl<In, InError, HigherOrderSubscriber, ErrorMapper, Destination> ObserverInput for HigherOrderAllSubscriber<In, InError, HigherOrderSubscriber, ErrorMapper, Destination>

where In: Signal + Observable, InError: Signal, HigherOrderSubscriber: HigherOrderSubscriberProvider, ErrorMapper: 'static + FnOnce(InError) -> <In as ObservableOutput>::OutError + Send + Sync, Destination: 'static + Subscriber<In = <In as ObservableOutput>::Out, InError = <In as ObservableOutput>::OutError>,

type In = In

type InError = InError

impl<In, InError, InnerObservable, ErrorMapper, Destination> ObserverInput for CatchSubscriber<In, InError, InnerObservable, ErrorMapper, Destination>

where In: Signal, InError: Signal, InnerObservable: Observable<Out = In> + Signal, ErrorMapper: 'static + FnOnce(InError) -> InnerObservable + Send + Sync, Destination: 'static + Subscriber<In = In, InError = <InnerObservable as ObservableOutput>::OutError>,

type In = In

type InError = InError

impl<In, InError, Mapper, InnerObservable, HigherOrderSubscriber, ErrorMapper, Destination> ObserverInput for HigherOrderMapSubscriber<In, InError, Mapper, InnerObservable, HigherOrderSubscriber, ErrorMapper, Destination>

where In: Signal, InError: Signal, Mapper: FnMut(In) -> InnerObservable, InnerObservable: Observable + Signal, HigherOrderSubscriber: HigherOrderSubscriberProvider, ErrorMapper: 'static + FnOnce(InError) -> <InnerObservable as ObservableOutput>::OutError + Send + Sync, Destination: 'static + Subscriber<In = <InnerObservable as ObservableOutput>::Out, InError = <InnerObservable as ObservableOutput>::OutError>,

type In = In

type InError = InError

impl<In, InError, Mapper, Out, Destination> ObserverInput for MapSubscriber<In, InError, Mapper, Out, Destination>

where In: Signal, InError: Signal, Mapper: Fn(In) -> Out + Send + Sync, Out: Signal, Destination: Subscriber<In = Out, InError = InError>,

type In = In

type InError = InError

impl<In, InError, OnNext, Destination> ObserverInput for TapNextSubscriber<In, InError, OnNext, Destination>

where OnNext: 'static + FnMut(&In), Destination: Subscriber<In = In, InError = InError>, In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError, Out, OutError, Destination> ObserverInput for MapIntoSubscriber<In, InError, Out, OutError, Destination>

where In: Signal + Into<Out>, InError: Signal + Into<OutError>, Out: Signal, OutError: Signal, Destination: Subscriber<In = Out, InError = OutError>,

type In = In

type InError = InError

impl<In, InError, P, Destination> ObserverInput for FindIndexSubscriber<In, InError, P, Destination>

where In: Signal, InError: Signal, P: Fn(&In) -> bool, Destination: Subscriber<In = usize, InError = FindIndexOperatorError<InError>>,

type In = In

type InError = InError

impl<In, InError, Reducer, Out, Destination> ObserverInput for ReduceSubscriber<In, InError, Reducer, Out, Destination>

where In: Signal, InError: Signal, Reducer: Fn(&Out, In) -> Out + Send + Sync, Out: Signal + Clone, Destination: Subscriber<In = Out, InError = InError>,

type In = In

type InError = InError

impl<In, InError, Reducer, Out, Destination> ObserverInput for ScanSubscriber<In, InError, Reducer, Out, Destination>

where In: Signal, InError: Signal, Reducer: Fn(&Out, In) -> Out + Send + Sync, Out: Signal + Clone, Destination: Subscriber<In = Out, InError = InError>,

type In = In

type InError = InError

impl<In, InError, S> ObserverInput for Box<S>

where In: Signal, InError: Signal, S: Subscriber<In = In, InError = InError> + Send + Sync + ?Sized,

type In = In

type InError = InError

impl<In, InnerObservable, Destination> ObserverInput for WithLatestFromSubscriber<In, InnerObservable, Destination>

where In: Signal, InnerObservable: Observable, <InnerObservable as ObservableOutput>::Out: Clone, Destination: 'static + Subscriber<In = (In, <InnerObservable as ObservableOutput>::Out), InError = <InnerObservable as ObservableOutput>::OutError>,

type In = In

type InError = <Destination as ObserverInput>::InError

impl<InError, Destination> ObserverInput for FirstSubscriber<InError, Destination>

where InError: Signal, Destination: Subscriber<InError = FirstOperatorError<InError>>,

type In = <Destination as ObserverInput>::In

type InError = InError

impl<InError, Destination, S> ObserverInput for AdsrSubscriber<InError, Destination, S>

where InError: Signal, Destination: 'static + Subscriber<In = AdsrSignal, InError = InError>, S: Scheduler,

type In = AdsrTrigger

type InError = InError

impl<InError, P, Destination> ObserverInput for FindSubscriber<InError, P, Destination>

where InError: Signal, P: Fn(&<Destination as ObserverInput>::In) -> bool, Destination: Subscriber<InError = FindOperatorError<InError>>,

type In = <Destination as ObserverInput>::In

type InError = InError

impl<Inner, Destination> ObserverInput for CompositeSubscriber<Inner, Destination>

where Inner: Subscriber, Destination: RxObserver,

type In = <Inner as ObserverInput>::In

type InError = <Inner as ObserverInput>::InError

impl<InnerObservable, Destination> ObserverInput for ConcurrentSubscriber<InnerObservable, Destination>

where InnerObservable: Observable<Out = <Destination as ObserverInput>::In, OutError = <Destination as ObserverInput>::InError> + Signal, Destination: 'static + Subscriber,

type In = InnerObservable

type InError = <InnerObservable as ObservableOutput>::OutError

impl<InnerObservable, Destination> ObserverInput for ExhaustSubscriber<InnerObservable, Destination>

where InnerObservable: Observable + Signal, Destination: 'static + Subscriber<In = <InnerObservable as ObservableOutput>::Out, InError = <InnerObservable as ObservableOutput>::OutError>,

type In = InnerObservable

type InError = <InnerObservable as ObservableOutput>::OutError

impl<InnerObservable, Destination> ObserverInput for SwitchSubscriber<InnerObservable, Destination>

where InnerObservable: Observable + Signal, Destination: 'static + Subscriber<In = <InnerObservable as ObservableOutput>::Out, InError = <InnerObservable as ObservableOutput>::OutError>,

type In = InnerObservable

type InError = <InnerObservable as ObservableOutput>::OutError

impl<O> ObserverInput for Option<O>

where O: ObserverInput,

type In = <O as ObserverInput>::In

type InError = <O as ObserverInput>::InError

impl<OnNext, Destination> ObserverInput for OnNextSubscriber<OnNext, Destination>

where OnNext: 'static + FnMut(&<Destination as ObserverInput>::In, &mut dyn Subscriber<In = <Destination as ObserverInput>::In, InError = <Destination as ObserverInput>::InError>) -> bool + Send + Sync, Destination: Subscriber,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<ResultIn, ResultInError, InError, Destination> ObserverInput for LiftResultSubscriber<ResultIn, ResultInError, InError, Destination>

where ResultIn: Signal, ResultInError: Signal, InError: Signal, Destination: Subscriber<In = ResultIn, InError = ResultInError>,

type In = Result<ResultIn, ResultInError>

type InError = Infallible

impl<State, OnComplete, OnUnsubscribe, Destination> ObserverInput for HigherOrderInnerSubscriber<State, OnComplete, OnUnsubscribe, Destination>

where State: HigherOrderSubscriberStateConditions, OnComplete: FnOnce(usize), OnUnsubscribe: FnOnce(usize), Destination: 'static + Subscriber,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<TapDestination, Destination> ObserverInput for TapSubscriber<TapDestination, Destination>

where TapDestination: 'static + RxObserver<In = <Destination as ObserverInput>::In, InError = <Destination as ObserverInput>::InError> + Send + Sync, Destination: Subscriber,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<VariantSelector, Destination, O1, O2> ObserverInput for EitherSubscriber2<VariantSelector, Destination, O1, O2>

where VariantSelector: EitherNotificationSelector2<O1, O2>, Destination: Subscriber<In = EitherObservableNotification2<O1, O2>>, O1: Observable, <O1 as ObservableOutput>::OutError: Into<<Destination as ObserverInput>::InError>, O2: Observable, <O2 as ObservableOutput>::OutError: Into<<Destination as ObserverInput>::InError>,

type In = <<VariantSelector as EitherNotificationSelector2<O1, O2>>::Variant as ObservableOutput>::Out

type InError = <<VariantSelector as EitherNotificationSelector2<O1, O2>>::Variant as ObservableOutput>::OutError

Implementors

impl<ConnectorProvider> ObserverInput for ShareOperator<ConnectorProvider>

where ConnectorProvider: 'static + Provider, <ConnectorProvider as Provider>::Provided: SubjectLike + Clone,

type In = <<ConnectorProvider as Provider>::Provided as ObserverInput>::In

type InError = <<ConnectorProvider as Provider>::Provided as ObserverInput>::InError

impl<Destination> ObserverInput for ObserverSubscriber<Destination>

where Destination: RxObserver,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<Destination> ObserverInput for SharedSubscriber<Destination>

where Destination: Subscriber + UpgradeableObserver + Send + Sync,

type In = <Destination as ObserverInput>::In

type InError = <Destination as ObserverInput>::InError

impl<In> ObserverInput for ErrorBoundaryOperator<In>

where In: Signal,

type In = In

type InError = Infallible

impl<In, InError> ObserverInput for DynFnObserver<In, InError>

where In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for NoopObserver<In, InError>

where In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for PrintObserver<In, InError>

where In: Signal + Debug, InError: Signal + Debug,

type In = In

type InError = InError

impl<In, InError> ObserverInput for BufferCountOperator<In, InError>

where In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for CountOperator<In, InError>

where In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for DematerializeOperator<In, InError>

where In: Signal, InError: Signal,

type In = ObserverNotification<In, InError>

type InError = Infallible

impl<In, InError> ObserverInput for ElementAtOperator<In, InError>

where In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for EndWithOperator<In, InError>

where In: Signal + Clone, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for EnumerateOperator<In, InError>

where In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for FirstOperator<In, InError>

where In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for IdentityOperator<In, InError>

where In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for IntoResultOperator<In, InError>

where In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for IsEmptyOperator<In, InError>

where In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for LiftOptionOperator<In, InError>

where In: Signal, InError: Signal,

type In = Option<In>

type InError = InError

impl<In, InError> ObserverInput for MaterializeOperator<In, InError>

where In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for PairwiseOperator<In, InError>

where In: Signal + Clone, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for RetryOperator<In, InError>

where In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for SkipOperator<In, InError>

where In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for StartWithOperator<In, InError>

where In: Signal + Clone, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for TakeOperator<In, InError>

where In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for ErasedSubscriber<In, InError>

where In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError> ObserverInput for BehaviorSubject<In, InError>

where In: Signal + Clone, InError: Signal + Clone,

type In = In

type InError = InError

impl<In, InError> ObserverInput for PublishSubject<In, InError>

where In: Signal + Clone, InError: Signal + Clone,

type In = In

type InError = InError

impl<In, InError, Callback> ObserverInput for FinalizeOperator<In, InError, Callback>

where In: Signal, InError: Signal, Callback: 'static + Clone + FnOnce() + Send + Sync,

type In = In

type InError = InError

impl<In, InError, ErrorMapper> ObserverInput for ConcatAllOperator<In, InError, ErrorMapper>

where In: Observable + Signal, InError: Signal, ErrorMapper: 'static + FnOnce(InError) -> <In as ObservableOutput>::OutError + Clone + Send + Sync,

type In = In

type InError = InError

impl<In, InError, ErrorMapper> ObserverInput for ExhaustAllOperator<In, InError, ErrorMapper>

where ErrorMapper: 'static + FnOnce(InError) -> <In as ObservableOutput>::OutError + Send + Sync + Clone, In: Observable + Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError, ErrorMapper> ObserverInput for MergeAllOperator<In, InError, ErrorMapper>

where In: Observable + Signal, InError: Signal, ErrorMapper: 'static + FnOnce(InError) -> <In as ObservableOutput>::OutError + Clone + Send + Sync,

type In = In

type InError = InError

impl<In, InError, ErrorMapper> ObserverInput for SwitchAllOperator<In, InError, ErrorMapper>

where In: Observable + Signal, InError: Signal, ErrorMapper: 'static + FnOnce(InError) -> <In as ObservableOutput>::OutError + Clone + Send + Sync,

type In = In

type InError = InError

impl<In, InError, ErrorMapper, InnerObservable> ObserverInput for CatchOperator<In, InError, ErrorMapper, InnerObservable>

where In: Signal, InError: Signal, ErrorMapper: 'static + FnOnce(InError) -> InnerObservable + Clone + Send + Sync, InnerObservable: Observable<Out = In> + Signal,

type In = In

type InError = InError

impl<In, InError, ErrorMapper, OutError> ObserverInput for MapErrorOperator<In, InError, ErrorMapper, OutError>

where In: Signal, InError: Signal, ErrorMapper: 'static + FnOnce(InError) -> OutError + Clone + Send + Sync, OutError: Signal,

type In = In

type InError = InError

impl<In, InError, Fallback, S> ObserverInput for FallbackWhenSilentOperator<In, InError, Fallback, S>

where In: Signal, InError: Signal, Fallback: 'static + Fn(<S as WithWorkInputOutput>::Tick, &mut <<S as WithWorkContextProvider>::WorkContextProvider as WorkContextProvider>::Item<'_>, usize) -> In + Clone + Send + Sync, S: Scheduler,

type In = In

type InError = InError

impl<In, InError, Filter> ObserverInput for FilterOperator<In, InError, Filter>

where In: Signal, InError: Signal, Filter: 'static + for<'a> Fn(&'a In, usize) -> bool + Clone + Send + Sync,

type In = In

type InError = InError

impl<In, InError, Mapper, ErrorMapper, InnerObservable> ObserverInput for ConcatMapOperator<In, InError, Mapper, ErrorMapper, InnerObservable>

where In: Signal, InError: Signal, Mapper: 'static + FnMut(In) -> InnerObservable + Clone + Send + Sync, ErrorMapper: 'static + FnOnce(InError) -> <InnerObservable as ObservableOutput>::OutError + Clone + Send + Sync, InnerObservable: Observable + Signal,

type In = In

type InError = InError

impl<In, InError, Mapper, ErrorMapper, InnerObservable> ObserverInput for ExhaustMapOperator<In, InError, Mapper, ErrorMapper, InnerObservable>

where In: Signal, InError: Signal + Into<<InnerObservable as ObservableOutput>::OutError>, Mapper: 'static + FnMut(In) -> InnerObservable + Clone + Send + Sync, ErrorMapper: 'static + FnOnce(InError) -> <InnerObservable as ObservableOutput>::OutError + Clone + Send + Sync, InnerObservable: Observable + Signal,

type In = In

type InError = InError

impl<In, InError, Mapper, ErrorMapper, InnerObservable> ObserverInput for MergeMapOperator<In, InError, Mapper, ErrorMapper, InnerObservable>

where In: Signal, InError: Signal, Mapper: 'static + FnMut(In) -> InnerObservable + Clone + Send + Sync, ErrorMapper: 'static + FnOnce(InError) -> <InnerObservable as ObservableOutput>::OutError + Clone + Send + Sync, InnerObservable: Observable + Signal,

type In = In

type InError = InError

impl<In, InError, Mapper, ErrorMapper, InnerObservable> ObserverInput for SwitchMapOperator<In, InError, Mapper, ErrorMapper, InnerObservable>

where In: Signal, InError: Signal, Mapper: 'static + FnMut(In) -> InnerObservable + Clone + Send + Sync, ErrorMapper: 'static + FnOnce(InError) -> <InnerObservable as ObservableOutput>::OutError + Clone + Send + Sync, InnerObservable: Observable + Signal,

type In = In

type InError = InError

impl<In, InError, Mapper, Out> ObserverInput for FilterMapOperator<In, InError, Mapper, Out>

where In: Signal, InError: Signal, Mapper: 'static + Fn(In) -> Option<Out> + Clone + Send + Sync, Out: Signal,

type In = In

type InError = InError

impl<In, InError, Mapper, Out> ObserverInput for MapOperator<In, InError, Mapper, Out>

where In: Signal, InError: Signal, Mapper: 'static + Fn(In) -> Out + Clone + Send + Sync, Out: Signal,

type In = In

type InError = InError

impl<In, InError, OnNext> ObserverInput for TapNextOperator<In, InError, OnNext>

where In: Signal, InError: Signal, OnNext: 'static + FnMut(&In) + Clone + Send + Sync,

type In = In

type InError = InError

impl<In, InError, OnNext, OnError, OnComplete> ObserverInput for FnObserver<In, InError, OnNext, OnError, OnComplete>

where In: Signal, InError: Signal, OnNext: 'static + FnMut(In) + Send + Sync, OnError: 'static + FnOnce(InError) + Send + Sync, OnComplete: 'static + FnOnce() + Send + Sync,

type In = In

type InError = InError

impl<In, InError, Out, OutError> ObserverInput for MapIntoOperator<In, InError, Out, OutError>

where In: Signal + Into<Out>, InError: Signal + Into<OutError>, Out: Signal, OutError: Signal,

type In = In

type InError = InError

impl<In, InError, P> ObserverInput for FindIndexOperator<In, InError, P>

where P: 'static + Fn(&In) -> bool + Clone + Send + Sync, In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError, P> ObserverInput for FindOperator<In, InError, P>

where P: 'static + Fn(&In) -> bool + Clone + Send + Sync, In: Signal, InError: Signal,

type In = In

type InError = InError

impl<In, InError, Reducer> ObserverInput for AsyncSubject<In, InError, Reducer>

where Reducer: 'static + FnMut(In, In) -> In + Send + Sync, In: Signal + Clone, InError: Signal + Clone,

type In = In

type InError = InError

impl<In, InError, Reducer, Out> ObserverInput for ReduceOperator<In, InError, Reducer, Out>

where In: Signal, InError: Signal, Reducer: 'static + Fn(&Out, In) -> Out + Clone + Send + Sync, Out: Signal + Clone,

type In = In

type InError = InError

impl<In, InError, Reducer, Out> ObserverInput for ScanOperator<In, InError, Reducer, Out>

where In: Signal, InError: Signal, Reducer: 'static + Fn(&Out, In) -> Out + Clone + Send + Sync, Out: Signal + Clone,

type In = In

type InError = InError

impl<In, InError, S> ObserverInput for DebounceTimeOperator<In, InError, S>

where In: Signal, InError: Signal, S: Scheduler,

type In = In

type InError = InError

impl<In, InError, S> ObserverInput for DelayOperator<In, InError, S>

where In: Signal, InError: Signal, S: Scheduler,

type In = In

type InError = InError

impl<In, InError, S> ObserverInput for ObserveOnOperator<In, InError, S>

where In: Signal, InError: Signal, S: Scheduler,

type In = In

type InError = InError

impl<In, InError, S> ObserverInput for SubscribeOnOperator<In, InError, S>

where In: Signal, InError: Signal, S: Scheduler,

type In = In

type InError = InError

impl<In, InError, S> ObserverInput for ThrottleTimeOperator<In, InError, S>

where In: Signal, InError: Signal, S: Scheduler,

type In = In

type InError = InError

impl<In, OutError> ObserverInput for MapNeverErrorOperator<In, OutError>

where In: Signal, OutError: Signal,

type In = In

type InError = Infallible

impl<InError, S> ObserverInput for AdsrOperator<InError, S>

where InError: Signal, S: Scheduler,

type In = AdsrTrigger

type InError = InError

impl<InnerObservable, In, InError> ObserverInput for WithLatestFromOperator<InnerObservable, In, InError>

where InnerObservable: 'static + Observable<OutError = InError>, <InnerObservable as ObservableOutput>::Out: Clone, In: Signal, InError: Signal,

type In = In

type InError = InError

impl<InnerSubscriber, Destination> ObserverInput for OptionSubscriber<InnerSubscriber, Destination>

where InnerSubscriber: Subscriber, Destination: Subscriber<In = <InnerSubscriber as ObserverInput>::In, InError = <InnerSubscriber as ObserverInput>::InError>,

type In = <InnerSubscriber as ObserverInput>::In

type InError = <InnerSubscriber as ObserverInput>::InError

impl<OnNext, In, InError> ObserverInput for OnNextOperator<OnNext, In, InError>

where OnNext: 'static + FnMut(&In, &mut dyn Subscriber<In = In, InError = InError>) -> bool + Send + Sync + Clone, In: Signal, InError: Signal,

type In = In

type InError = InError

impl<OnSubscribe, In, InError> ObserverInput for OnSubscribeOperator<OnSubscribe, In, InError>

where OnSubscribe: 'static + FnMut(&mut dyn Subscriber<In = In, InError = InError>) + Send + Sync, In: Signal, InError: Signal,

type In = In

type InError = InError

impl<Op> ObserverInput for ComposeOperator<Op>

where Op: 'static + ComposableOperator,

type In = <Op as ObserverInput>::In

type InError = <Op as ObserverInput>::InError

impl<Out, InError> ObserverInput for MapNeverNextOperator<Out, InError>

where InError: Signal, Out: Signal,

type In = Infallible

type InError = InError

impl<Out, OutError> ObserverInput for MapNeverBothOperator<Out, OutError>

where Out: Signal, OutError: Signal,

type In = Infallible

type InError = Infallible

impl<PrevOp, Op> ObserverInput for CompositeOperator<PrevOp, Op>

where PrevOp: ComposableOperator<Out = <Op as ObserverInput>::In, OutError = <Op as ObserverInput>::InError>, Op: ComposableOperator,

type In = <PrevOp as ObserverInput>::In

type InError = <PrevOp as ObserverInput>::InError

impl<Provenance, In, InError> ObserverInput for ProvenanceSubject<Provenance, In, InError>

where Provenance: Signal + Clone + PartialEq, In: Signal + Clone, InError: Signal + Clone,

type In = (In, Provenance)

type InError = InError

impl<ResultIn, ResultInError, InError> ObserverInput for LiftResultOperator<ResultIn, ResultInError, InError>

where ResultIn: Signal, ResultInError: Signal, InError: Signal,

type In = Result<ResultIn, ResultInError>

type InError = Infallible

impl<TapDestination> ObserverInput for TapOperator<TapDestination>

where TapDestination: 'static + RxObserver + Send + Sync, <TapDestination as ObserverInput>::In: Clone, <TapDestination as ObserverInput>::InError: Clone,

type In = <TapDestination as ObserverInput>::In

type InError = <TapDestination as ObserverInput>::InError

impl<const CAPACITY: usize, In, InError> ObserverInput for ReplaySubject<CAPACITY, In, InError>

where In: Signal + Clone, InError: Signal + Clone,

type In = In

type InError = InError