Package rx.internal.operators
Class OnSubscribeCombineLatest.LatestCoordinator<T,R>
- java.lang.Object
-
- java.lang.Number
-
- java.util.concurrent.atomic.AtomicInteger
-
- rx.internal.operators.OnSubscribeCombineLatest.LatestCoordinator<T,R>
-
- All Implemented Interfaces:
java.io.Serializable
,Producer
,Subscription
- Enclosing class:
- OnSubscribeCombineLatest<T,R>
static final class OnSubscribeCombineLatest.LatestCoordinator<T,R> extends java.util.concurrent.atomic.AtomicInteger implements Producer, Subscription
-
-
Field Summary
Fields Modifier and Type Field Description (package private) int
active
(package private) Subscriber<? super R>
actual
(package private) int
bufferSize
(package private) boolean
cancelled
(package private) FuncN<? extends R>
combiner
(package private) int
complete
(package private) int
count
(package private) boolean
delayError
(package private) boolean
done
(package private) java.util.concurrent.atomic.AtomicReference<java.lang.Throwable>
error
(package private) java.lang.Object[]
latest
(package private) static java.lang.Object
MISSING
Indicates the particular source hasn't emitted any value yet.(package private) SpscLinkedArrayQueue<java.lang.Object>
queue
(package private) java.util.concurrent.atomic.AtomicLong
requested
private static long
serialVersionUID
(package private) OnSubscribeCombineLatest.CombinerSubscriber<T,R>[]
subscribers
-
Constructor Summary
Constructors Constructor Description LatestCoordinator(Subscriber<? super R> actual, FuncN<? extends R> combiner, int count, int bufferSize, boolean delayError)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
cancel(java.util.Queue<?> q)
(package private) boolean
checkTerminated(boolean mainDone, boolean queueEmpty, Subscriber<?> childSubscriber, java.util.Queue<?> q, boolean delayError)
(package private) void
combine(java.lang.Object value, int index)
Combine the given notification value from the indexth source with the existing known latest values.(package private) void
drain()
boolean
isUnsubscribed()
Indicates whether thisSubscription
is currently unsubscribed.(package private) void
onError(java.lang.Throwable e)
void
request(long n)
Request a certain maximum number of items from this Producer.void
subscribe(Observable<? extends T>[] sources)
void
unsubscribe()
Stops the receipt of notifications on theSubscriber
that was registered when this Subscription was received.-
Methods inherited from class java.util.concurrent.atomic.AtomicInteger
accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
actual
final Subscriber<? super R> actual
-
count
final int count
-
subscribers
final OnSubscribeCombineLatest.CombinerSubscriber<T,R>[] subscribers
-
bufferSize
final int bufferSize
-
latest
final java.lang.Object[] latest
-
queue
final SpscLinkedArrayQueue<java.lang.Object> queue
-
delayError
final boolean delayError
-
cancelled
volatile boolean cancelled
-
done
volatile boolean done
-
requested
final java.util.concurrent.atomic.AtomicLong requested
-
error
final java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> error
-
active
int active
-
complete
int complete
-
MISSING
static final java.lang.Object MISSING
Indicates the particular source hasn't emitted any value yet.
-
-
Constructor Detail
-
LatestCoordinator
public LatestCoordinator(Subscriber<? super R> actual, FuncN<? extends R> combiner, int count, int bufferSize, boolean delayError)
-
-
Method Detail
-
subscribe
public void subscribe(Observable<? extends T>[] sources)
-
request
public void request(long n)
Description copied from interface:Producer
Request a certain maximum number of items from this Producer. This is a way of requesting backpressure. To disable backpressure, passLong.MAX_VALUE
to this method.Requests are additive but if a sequence of requests totals more than
Long.MAX_VALUE
thenLong.MAX_VALUE
requests will be actioned and the extras may be ignored. Arriving atLong.MAX_VALUE
by addition of requests cannot be assumed to disable backpressure. For example, the code below may result inLong.MAX_VALUE
requests being actioned only.request(100); request(Long.MAX_VALUE-1);
-
unsubscribe
public void unsubscribe()
Description copied from interface:Subscription
Stops the receipt of notifications on theSubscriber
that was registered when this Subscription was received.This allows unregistering an
Subscriber
before it has finished receiving all events (i.e. before onCompleted is called).- Specified by:
unsubscribe
in interfaceSubscription
-
isUnsubscribed
public boolean isUnsubscribed()
Description copied from interface:Subscription
Indicates whether thisSubscription
is currently unsubscribed.- Specified by:
isUnsubscribed
in interfaceSubscription
- Returns:
true
if thisSubscription
is currently unsubscribed,false
otherwise
-
cancel
void cancel(java.util.Queue<?> q)
-
combine
void combine(java.lang.Object value, int index)
Combine the given notification value from the indexth source with the existing known latest values.- Parameters:
value
- the notification to combine, null indicates the source terminated normallyindex
- the index of the source subscriber
-
drain
void drain()
-
checkTerminated
boolean checkTerminated(boolean mainDone, boolean queueEmpty, Subscriber<?> childSubscriber, java.util.Queue<?> q, boolean delayError)
-
onError
void onError(java.lang.Throwable e)
-
-