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 ProducerArbiterOnSubscribeConcatMap.ConcatMapSubscriber.arbiterprivate final ProducerArbiterOperatorSwitchIfEmpty.AlternateSubscriber.arbiterprivate final ProducerArbiterOperatorSwitchIfEmpty.ParentSubscriber.arbiter(package private) final ProducerArbiterOperatorTimeoutBase.TimeoutSubscriber.arbiter(package private) final ProducerArbiterOperatorRetryWithPredicate.SourceSubscriber.pa(package private) final ProducerArbiterOperatorGroupBy.GroupBySubscriber.sConstructors 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)