Class FlowableAmb.AmbCoordinator<T>
java.lang.Object
io.reactivex.rxjava3.internal.operators.flowable.FlowableAmb.AmbCoordinator<T>
- All Implemented Interfaces:
org.reactivestreams.Subscription
- Enclosing class:
FlowableAmb<T>
static final class FlowableAmb.AmbCoordinator<T>
extends Object
implements org.reactivestreams.Subscription
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final org.reactivestreams.Subscriber
<? super T> (package private) final FlowableAmb.AmbInnerSubscriber<T>[]
(package private) final AtomicInteger
-
Constructor Summary
Constructors -
Method Summary
-
Field Details
-
downstream
-
subscribers
-
winner
-
-
Constructor Details
-
AmbCoordinator
AmbCoordinator(org.reactivestreams.Subscriber<? super T> actual, int count)
-
-
Method Details
-
subscribe
-
request
public void request(long n) - Specified by:
request
in interfaceorg.reactivestreams.Subscription
-
win
public boolean win(int index) -
cancel
public void cancel()- Specified by:
cancel
in interfaceorg.reactivestreams.Subscription
-