Trait WithPrimaryCategory 

pub trait WithPrimaryCategory {
    type PrimaryCategory: PrimaryCategoryMarker;
}

Marks a type with a distinct conceptual category to offer granular scoping for blanket implementation. (Since negative trait bounds aren’t a thing)

For example, it’s impossible to only implement something for all observers without also having to use the same implementations for all subscribers and all subjects too, since they are all also observers!

Required Associated Types

type PrimaryCategory: PrimaryCategoryMarker

Implementations on Foreign Types

impl WithPrimaryCategory for InertSubscription

type PrimaryCategory = PrimaryCategorySubscription

impl<'o, Source> WithPrimaryCategory for RetryObservable<'o, Source>

where Source: 'o + Observable,

type PrimaryCategory = PrimaryCategoryObservable

impl<Destination> WithPrimaryCategory for Arc<Mutex<Destination>>

where Destination: WithPrimaryCategory + ?Sized,

type PrimaryCategory = PrimaryCategorySubscriber

impl<Destination> WithPrimaryCategory for Arc<RwLock<Destination>>

where Destination: WithPrimaryCategory + ?Sized,

type PrimaryCategory = PrimaryCategorySubscriber

impl<Destination> WithPrimaryCategory for Weak<Mutex<Destination>>

where Destination: WithPrimaryCategory + ?Sized,

type PrimaryCategory = PrimaryCategorySubscriber

impl<Destination> WithPrimaryCategory for DematerializeSubscriber<Destination>

where Destination: Subscriber,

type PrimaryCategory = PrimaryCategorySubscriber

impl<Destination> WithPrimaryCategory for EndWithSubscriber<Destination>

where Destination: Subscriber,

type PrimaryCategory = PrimaryCategorySubscriber

impl<Destination> WithPrimaryCategory for ErrorBoundarySubscriber<Destination>

where Destination: Subscriber<InError = Infallible>,

type PrimaryCategory = PrimaryCategorySubscriber

impl<Destination> WithPrimaryCategory for IdentitySubscriber<Destination>

where Destination: Subscriber,

type PrimaryCategory = PrimaryCategorySubscriber

impl<Destination> WithPrimaryCategory for LiftOptionSubscriber<Destination>

where Destination: Subscriber,

type PrimaryCategory = PrimaryCategorySubscriber

impl<Destination> WithPrimaryCategory for MapNeverBothSubscriber<Destination>

where Destination: Subscriber,

type PrimaryCategory = PrimaryCategorySubscriber

impl<Destination> WithPrimaryCategory for MapNeverErrorSubscriber<Destination>

where Destination: Subscriber,

type PrimaryCategory = PrimaryCategorySubscriber

impl<Destination> WithPrimaryCategory for MapNeverNextSubscriber<Destination>

where Destination: Subscriber,

type PrimaryCategory = PrimaryCategorySubscriber

impl<Destination> WithPrimaryCategory for SkipSubscriber<Destination>

where Destination: Subscriber,

type PrimaryCategory = PrimaryCategorySubscriber

impl<Destination> WithPrimaryCategory for TakeSubscriber<Destination>

where Destination: Subscriber,

type PrimaryCategory = PrimaryCategorySubscriber

impl<Destination, Iterator, S> WithPrimaryCategory for OnTickIteratorSubscription<Destination, Iterator, S>

where Destination: 'static + Subscriber<In = <Iterator as IntoIterator>::Item, InError = Infallible>, Iterator: IntoIterator, <Iterator as IntoIterator>::Item: Signal, S: Scheduler,

type PrimaryCategory = PrimaryCategorySubscription

impl<Destination, O1, O2> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategorySubscriber

impl<Destination, O1, O2> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategorySubscriber

impl<Destination, O1, O2> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategorySubscriber

impl<Destination, O1, O2> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategorySubscriber

impl<Destination, S> WithPrimaryCategory for IntervalSubscription<Destination, S>

where Destination: 'static + Subscriber<In = usize>, S: Scheduler,

type PrimaryCategory = PrimaryCategorySubscription

impl<Destination, S> WithPrimaryCategory for TimerSubscription<Destination, S>

where Destination: 'static + Subscriber<In = ()>, S: Scheduler,

type PrimaryCategory = PrimaryCategorySubscription

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategoryObserver

impl<In, InError> WithPrimaryCategory for MulticastSubscription<In, InError>

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

type PrimaryCategory = PrimaryCategorySubscription

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

impl<In, InError, ErrorMapper, OutError, Destination> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategorySubscriber

impl<In, InError, Fallback, Destination, S> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategorySubscriber

impl<In, InError, HigherOrderSubscriber, ErrorMapper, Destination> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategorySubscriber

impl<In, InError, InnerObservable, ErrorMapper, Destination> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategorySubscriber

impl<In, InError, Mapper, InnerObservable, HigherOrderSubscriber, ErrorMapper, Destination> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategorySubscriber

impl<In, InError, Mapper, Out, Destination> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

impl<In, InError, Out, OutError, Destination> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

impl<In, InError, Reducer, Out, Destination> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategorySubscriber

impl<In, InError, Reducer, Out, Destination> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

impl<In, InnerObservable, Destination> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

where Inner: Subscriber, Destination: RxObserver,

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

impl<O> WithPrimaryCategory for Option<O>

where O: WithPrimaryCategory,

type PrimaryCategory = <O as WithPrimaryCategory>::PrimaryCategory

impl<OnNext, Destination> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

impl<Source, ConnectorProvider> WithPrimaryCategory for ShareObservable<Source, ConnectorProvider>

where Source: Observable, <Source as ObservableOutput>::Out: Clone, <Source as ObservableOutput>::OutError: Clone, ConnectorProvider: 'static + Provider, <ConnectorProvider as Provider>::Provided: SubjectLike<In = <Source as ObservableOutput>::Out, InError = <Source as ObservableOutput>::OutError> + Clone,

type PrimaryCategory = PrimaryCategoryObservable

impl<Source, S> WithPrimaryCategory for SubscribeOnObservable<Source, S>

where Source: 'static + Observable, S: Scheduler,

type PrimaryCategory = PrimaryCategoryObservable

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

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

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubscriber

impl<VariantSelector, Destination, O1, O2> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategorySubscriber

Implementors

impl WithPrimaryCategory for ClosedObservable

type PrimaryCategory = PrimaryCategoryObservable

impl WithPrimaryCategory for EmptyObservable

type PrimaryCategory = PrimaryCategoryObservable

impl WithPrimaryCategory for NeverObservable

type PrimaryCategory = PrimaryCategoryObservable

impl WithPrimaryCategory for ErasedSubscription

type PrimaryCategory = PrimaryCategorySubscription

impl WithPrimaryCategory for SharedSubscription

type PrimaryCategory = PrimaryCategorySubscription

impl<ConnectorProvider> WithPrimaryCategory for ShareOperator<ConnectorProvider>

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

type PrimaryCategory = PrimaryCategoryOperator

impl<Destination> WithPrimaryCategory for ObserverSubscriber<Destination>

where Destination: RxObserver,

type PrimaryCategory = PrimaryCategorySubscriber

impl<Destination> WithPrimaryCategory for SharedSubscriber<Destination>

where Destination: Subscriber + UpgradeableObserver + Send + Sync,

type PrimaryCategory = PrimaryCategorySubscriber

impl<Destination> WithPrimaryCategory for Subscription<Destination>

where Destination: Subscriber,

type PrimaryCategory = PrimaryCategorySubscription

impl<F, Source> WithPrimaryCategory for DeferredObservable<F, Source>

where Source: Observable, F: FnMut() -> Source,

type PrimaryCategory = PrimaryCategoryObservable

impl<In> WithPrimaryCategory for ErrorBoundaryOperator<In>

where In: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal, InError: Signal,

type PrimaryCategory = PrimaryCategoryObserver

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

where In: Signal, InError: Signal,

type PrimaryCategory = PrimaryCategoryObserver

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

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

type PrimaryCategory = PrimaryCategoryObserver

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

where In: Signal, InError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal, InError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal, InError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal, InError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal + Clone, InError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal, InError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal, InError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal, InError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal, InError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal, InError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal, InError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal, InError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal + Clone, InError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal, InError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal, InError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal + Clone, InError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal, InError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal, InError: Signal,

type PrimaryCategory = PrimaryCategorySubscriber

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

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

type PrimaryCategory = PrimaryCategorySubject

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

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

type PrimaryCategory = PrimaryCategorySubject

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

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

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

impl<In, InError, ErrorMapper, InnerObservable> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

impl<In, InError, Fallback, S> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

impl<In, InError, Mapper, ErrorMapper, InnerObservable> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategoryOperator

impl<In, InError, Mapper, ErrorMapper, InnerObservable> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategoryOperator

impl<In, InError, Mapper, ErrorMapper, InnerObservable> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategoryOperator

impl<In, InError, Mapper, ErrorMapper, InnerObservable> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

impl<In, InError, OnNext, OnError, OnComplete> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategoryObserver

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

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

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategorySubject

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

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

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

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

where In: Signal, OutError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where InError: Signal, S: Scheduler,

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategorySubscriber

impl<Iterator> WithPrimaryCategory for IteratorObservable<Iterator>

where Iterator: Clone + IntoIterator, <Iterator as IntoIterator>::Item: Signal,

type PrimaryCategory = PrimaryCategoryObservable

impl<Iterator, S> WithPrimaryCategory for IteratorOnTickObservable<Iterator, S>

where Iterator: 'static + Clone + IntoIterator, <Iterator as IntoIterator>::Item: Signal, S: Scheduler,

type PrimaryCategory = PrimaryCategoryObservable

impl<O1, O2> WithPrimaryCategory for CombineChangesObservable<O1, O2>

where O1: 'static + Send + Sync + Observable, <O1 as ObservableOutput>::Out: Clone, O2: 'static + Send + Sync + Observable, <O2 as ObservableOutput>::Out: Clone, <O2 as ObservableOutput>::OutError: Into<<O1 as ObservableOutput>::OutError>,

type PrimaryCategory = PrimaryCategoryObservable

impl<O1, O2> WithPrimaryCategory for CombineLatestObservable<O1, O2>

where O1: 'static + Send + Sync + Observable, <O1 as ObservableOutput>::Out: Clone, O2: 'static + Send + Sync + Observable, <O2 as ObservableOutput>::Out: Clone, <O2 as ObservableOutput>::OutError: Into<<O1 as ObservableOutput>::OutError>,

type PrimaryCategory = PrimaryCategoryObservable

impl<O1, O2> WithPrimaryCategory for JoinObservable<O1, O2>

where O1: 'static + Send + Sync + Observable, <O1 as ObservableOutput>::Out: Clone, O2: 'static + Send + Sync + Observable, <O2 as ObservableOutput>::Out: Clone, <O2 as ObservableOutput>::OutError: Into<<O1 as ObservableOutput>::OutError>,

type PrimaryCategory = PrimaryCategoryObservable

impl<O1, O2> WithPrimaryCategory for ZipObservable<O1, O2>

where O1: 'static + Send + Sync + Observable, <O1 as ObservableOutput>::Out: Clone, O2: 'static + Send + Sync + Observable, <O2 as ObservableOutput>::Out: Clone, <O2 as ObservableOutput>::OutError: Into<<O1 as ObservableOutput>::OutError>,

type PrimaryCategory = PrimaryCategoryObservable

impl<OnNext, In, InError> WithPrimaryCategory 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 PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategoryOperator

impl<Op> WithPrimaryCategory for ComposeOperator<Op>

where Op: 'static + ComposableOperator,

type PrimaryCategory = PrimaryCategoryOperator

impl<Out> WithPrimaryCategory for JustObservable<Out>

where Out: Signal + Clone,

type PrimaryCategory = PrimaryCategoryObservable

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

where InError: Signal, Out: Signal,

type PrimaryCategory = PrimaryCategoryOperator

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

where Out: Signal, OutError: Signal,

type PrimaryCategory = PrimaryCategoryOperator

impl<Out, OutError> WithPrimaryCategory for ErasedObservable<Out, OutError>

where Out: Signal, OutError: Signal,

type PrimaryCategory = PrimaryCategoryObservable

impl<Out, OutError, const SIZE: usize> WithPrimaryCategory for ConcatObservable<Out, OutError, SIZE>

where Out: Signal, OutError: Signal,

type PrimaryCategory = PrimaryCategoryObservable

impl<Out, OutError, const SIZE: usize> WithPrimaryCategory for MergeObservable<Out, OutError, SIZE>

where Out: Signal, OutError: Signal,

type PrimaryCategory = PrimaryCategoryObservable

impl<OutError> WithPrimaryCategory for ThrowObservable<OutError>

where OutError: Signal + Clone,

type PrimaryCategory = PrimaryCategoryObservable

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

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

type PrimaryCategory = PrimaryCategoryOperator

impl<Producer, Out, OutError> WithPrimaryCategory for CreateObservable<Producer, Out, OutError>

where Out: Signal, OutError: Signal, Producer: Clone + FnOnce(&mut dyn Subscriber<In = Out, InError = OutError>),

type PrimaryCategory = PrimaryCategoryObservable

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

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

type PrimaryCategory = PrimaryCategorySubject

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

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

type PrimaryCategory = PrimaryCategoryOperator

impl<S> WithPrimaryCategory for IntervalObservable<S>

where S: Scheduler,

type PrimaryCategory = PrimaryCategoryObservable

impl<S> WithPrimaryCategory for TimerObservable<S>

where S: Scheduler,

type PrimaryCategory = PrimaryCategoryObservable

impl<Source, ConnectorProvider> WithPrimaryCategory for ConnectableObservable<Source, ConnectorProvider>

where Source: Observable, ConnectorProvider: 'static + Provider, <ConnectorProvider as Provider>::Provided: SubjectLike<In = <Source as ObservableOutput>::Out, InError = <Source as ObservableOutput>::OutError> + Clone, <Source as Observable>::Subscription<ConnectionSubscriber<<ConnectorProvider as Provider>::Provided>>: 'static + TeardownCollection,

type PrimaryCategory = PrimaryCategoryObservable

impl<Source, Op> WithPrimaryCategory for Pipe<Source, Op>

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

type PrimaryCategory = PrimaryCategoryObservable

impl<Subscription> WithPrimaryCategory for ConnectionHandle<Subscription>

where Subscription: SubscriptionWithTeardown,

type PrimaryCategory = PrimaryCategorySubscription

impl<TapDestination> WithPrimaryCategory for TapOperator<TapDestination>

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

type PrimaryCategory = PrimaryCategoryOperator

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

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

type PrimaryCategory = PrimaryCategorySubject