Uses of Class
io.reactivex.rxjava3.internal.subscriptions.DeferredScalarSubscription

Packages that use DeferredScalarSubscription

Package	Description
io.reactivex.rxjava3.internal.jdk8
io.reactivex.rxjava3.internal.operators.flowable
io.reactivex.rxjava3.internal.operators.maybe
io.reactivex.rxjava3.internal.operators.parallel
io.reactivex.rxjava3.internal.operators.single
io.reactivex.rxjava3.internal.subscribers
io.reactivex.rxjava3.processors	Classes representing so-called hot backpressure-aware sources, aka processors, that implement the FlowableProcessor class, the Reactive Streams Processor interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive Streams Publisher.

Uses of DeferredScalarSubscription in io.reactivex.rxjava3.internal.jdk8

Subclasses of DeferredScalarSubscription in io.reactivex.rxjava3.internal.jdk8

Modifier and Type	Class	Description
(package private) static class	FlowableCollectWithCollector.CollectorSubscriber<T,A,R>
(package private) static class	FlowableFromCompletionStage.CompletionStageHandler<T>
(package private) static class	ParallelCollector.ParallelCollectorSubscriber<T,A,R>

Uses of DeferredScalarSubscription in io.reactivex.rxjava3.internal.operators.flowable

Subclasses of DeferredScalarSubscription in io.reactivex.rxjava3.internal.operators.flowable

Modifier and Type	Class	Description
(package private) static class	FlowableAll.AllSubscriber<T>
(package private) static class	FlowableAny.AnySubscriber<T>
(package private) static class	FlowableCollect.CollectSubscriber<T,U>
(package private) static class	FlowableCount.CountSubscriber
(package private) static class	FlowableElementAt.ElementAtSubscriber<T>
(package private) static class	FlowableReduce.ReduceSubscriber<T>
(package private) static class	FlowableSequenceEqual.EqualCoordinator<T>
(package private) static class	FlowableSingle.SingleElementSubscriber<T>
(package private) static class	FlowableTakeLastOne.TakeLastOneSubscriber<T>
(package private) static class	FlowableToList.ToListSubscriber<T,U extends java.util.Collection<? super T>>

Uses of DeferredScalarSubscription in io.reactivex.rxjava3.internal.operators.maybe

Subclasses of DeferredScalarSubscription in io.reactivex.rxjava3.internal.operators.maybe

Modifier and Type	Class	Description
(package private) static class	MaybeToFlowable.MaybeToFlowableSubscriber<T>

Uses of DeferredScalarSubscription in io.reactivex.rxjava3.internal.operators.parallel

Subclasses of DeferredScalarSubscription in io.reactivex.rxjava3.internal.operators.parallel

Modifier and Type	Class	Description
(package private) static class	ParallelCollect.ParallelCollectSubscriber<T,C>
(package private) static class	ParallelReduce.ParallelReduceSubscriber<T,R>
(package private) static class	ParallelReduceFull.ParallelReduceFullMainSubscriber<T>

Uses of DeferredScalarSubscription in io.reactivex.rxjava3.internal.operators.single

Subclasses of DeferredScalarSubscription in io.reactivex.rxjava3.internal.operators.single

Modifier and Type	Class	Description
(package private) static class	SingleToFlowable.SingleToFlowableObserver<T>

Uses of DeferredScalarSubscription in io.reactivex.rxjava3.internal.subscribers

Subclasses of DeferredScalarSubscription in io.reactivex.rxjava3.internal.subscribers

Modifier and Type	Class	Description
class	DeferredScalarSubscriber<T,R>	A subscriber, extending a DeferredScalarSubscription, that is unbounded-in and can generate 0 or 1 resulting value.

Uses of DeferredScalarSubscription in io.reactivex.rxjava3.processors

Subclasses of DeferredScalarSubscription in io.reactivex.rxjava3.processors

Modifier and Type	Class	Description
(package private) static class	AsyncProcessor.AsyncSubscription<T>