Uses of Class
rx.internal.producers.ProducerArbiter
Packages that use ProducerArbiter
Package
Description
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
-
Uses of ProducerArbiter in rx.internal.operators
Fields in rx.internal.operators declared as ProducerArbiterModifier and TypeFieldDescription(package private) final ProducerArbiter
OnSubscribeConcatMap.ConcatMapSubscriber.arbiter
private final ProducerArbiter
OperatorSwitchIfEmpty.AlternateSubscriber.arbiter
private final ProducerArbiter
OperatorSwitchIfEmpty.ParentSubscriber.arbiter
(package private) final ProducerArbiter
OperatorTimeoutBase.TimeoutSubscriber.arbiter
(package private) final ProducerArbiter
OperatorRetryWithPredicate.SourceSubscriber.pa
(package private) final ProducerArbiter
OperatorGroupBy.GroupBySubscriber.s
Constructors in rx.internal.operators with parameters of type ProducerArbiterModifierConstructorDescription(package private)
AlternateSubscriber
(Subscriber<? super T> child, ProducerArbiter arbiter) (package private)
ParentSubscriber
(Subscriber<? super T> child, SerialSubscription ssub, ProducerArbiter arbiter, Observable<? extends T> alternate) SourceSubscriber
(Subscriber<? super T> child, Func2<Integer, Throwable, Boolean> predicate, Scheduler.Worker inner, SerialSubscription serialSubscription, ProducerArbiter pa)