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 java.lang.Object implements org.reactivestreams.Subscription
-
-
Field Summary
Fields Modifier and Type Field Description (package private) org.reactivestreams.Subscriber<? super T>
downstream
(package private) FlowableAmb.AmbInnerSubscriber<T>[]
subscribers
(package private) java.util.concurrent.atomic.AtomicInteger
winner
-
Constructor Summary
Constructors Constructor Description AmbCoordinator(org.reactivestreams.Subscriber<? super T> actual, int count)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancel()
void
request(long n)
void
subscribe(org.reactivestreams.Publisher<? extends T>[] sources)
boolean
win(int index)
-
-
-
Field Detail
-
downstream
final org.reactivestreams.Subscriber<? super T> downstream
-
subscribers
final FlowableAmb.AmbInnerSubscriber<T>[] subscribers
-
winner
final java.util.concurrent.atomic.AtomicInteger winner
-
-
Constructor Detail
-
AmbCoordinator
AmbCoordinator(org.reactivestreams.Subscriber<? super T> actual, int count)
-
-
Method Detail
-
subscribe
public void subscribe(org.reactivestreams.Publisher<? extends T>[] sources)
-
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
-
-