Uses of Class
rx.internal.producers.ProducerArbiter
-
Packages that use ProducerArbiter Package Description rx.internal.operators 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 ProducerArbiter Modifier and Type Field Description (package private) ProducerArbiter
OnSubscribeConcatMap.ConcatMapSubscriber. arbiter
private ProducerArbiter
OperatorSwitchIfEmpty.AlternateSubscriber. arbiter
private ProducerArbiter
OperatorSwitchIfEmpty.ParentSubscriber. arbiter
(package private) ProducerArbiter
OperatorTimeoutBase.TimeoutSubscriber. arbiter
(package private) ProducerArbiter
OperatorRetryWithPredicate.SourceSubscriber. pa
(package private) ProducerArbiter
OperatorGroupBy.GroupBySubscriber. s
Constructors in rx.internal.operators with parameters of type ProducerArbiter Constructor Description AlternateSubscriber(Subscriber<? super T> child, ProducerArbiter arbiter)
ParentSubscriber(Subscriber<? super T> child, SerialSubscription ssub, ProducerArbiter arbiter, Observable<? extends T> alternate)
SourceSubscriber(Subscriber<? super T> child, Func2<java.lang.Integer,java.lang.Throwable,java.lang.Boolean> predicate, Scheduler.Worker inner, SerialSubscription serialSubscription, ProducerArbiter pa)
-