Class FlowableGroupBy.State<T,K>
- java.lang.Object
-
- java.lang.Number
-
- java.util.concurrent.atomic.AtomicInteger
-
- io.reactivex.rxjava3.internal.subscriptions.BasicIntQueueSubscription<T>
-
- io.reactivex.rxjava3.internal.operators.flowable.FlowableGroupBy.State<T,K>
-
- All Implemented Interfaces:
QueueFuseable<T>
,QueueSubscription<T>
,SimpleQueue<T>
,java.io.Serializable
,org.reactivestreams.Publisher<T>
,org.reactivestreams.Subscription
- Enclosing class:
- FlowableGroupBy<T,K,V>
static final class FlowableGroupBy.State<T,K> extends BasicIntQueueSubscription<T> implements org.reactivestreams.Publisher<T>
-
-
Field Summary
Fields Modifier and Type Field Description (package private) static int
ABANDONED
(package private) static int
ABANDONED_HAS_SUBSCRIBER
(package private) java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscriber<? super T>>
actual
(package private) java.util.concurrent.atomic.AtomicBoolean
cancelled
(package private) boolean
delayError
(package private) boolean
done
(package private) java.lang.Throwable
error
(package private) java.util.concurrent.atomic.AtomicBoolean
evictOnce
(package private) static int
FRESH
(package private) static int
HAS_SUBSCRIBER
(package private) K
key
(package private) java.util.concurrent.atomic.AtomicInteger
once
(package private) boolean
outputFused
(package private) FlowableGroupBy.GroupBySubscriber<?,K,T>
parent
(package private) int
produced
(package private) SpscLinkedArrayQueue<T>
queue
(package private) java.util.concurrent.atomic.AtomicLong
requested
private static long
serialVersionUID
-
Constructor Summary
Constructors Constructor Description State(int bufferSize, FlowableGroupBy.GroupBySubscriber<?,K,T> parent, K key, boolean delayError)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancel()
(package private) void
cancelParent()
(package private) boolean
checkTerminated(boolean d, boolean empty, org.reactivestreams.Subscriber<? super T> a, boolean delayError, long emitted, boolean polled)
(package private) void
cleanupQueue(long emitted, boolean polled)
void
clear()
Removes all enqueued items from this queue.(package private) void
drain()
(package private) void
drainFused()
(package private) void
drainNormal()
boolean
isEmpty()
Returns true if the queue is empty.void
onComplete()
void
onError(java.lang.Throwable e)
void
onNext(T t)
T
poll()
Tries to dequeue a value (non-null) or returns null if the queue is empty.(package private) void
replenishParent(long emitted, boolean polled)
void
request(long n)
int
requestFusion(int mode)
Request a fusion mode from the upstream.(package private) void
requestParent(long e)
void
subscribe(org.reactivestreams.Subscriber<? super T> subscriber)
(package private) boolean
tryAbandon()
(package private) boolean
tryComplete()
(package private) void
tryReplenish()
-
Methods inherited from class io.reactivex.rxjava3.internal.subscriptions.BasicIntQueueSubscription
offer, offer
-
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
-
key
final K key
-
queue
final SpscLinkedArrayQueue<T> queue
-
parent
final FlowableGroupBy.GroupBySubscriber<?,K,T> parent
-
delayError
final boolean delayError
-
requested
final java.util.concurrent.atomic.AtomicLong requested
-
done
volatile boolean done
-
error
java.lang.Throwable error
-
cancelled
final java.util.concurrent.atomic.AtomicBoolean cancelled
-
actual
final java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscriber<? super T>> actual
-
outputFused
boolean outputFused
-
produced
int produced
-
once
final java.util.concurrent.atomic.AtomicInteger once
-
FRESH
static final int FRESH
- See Also:
- Constant Field Values
-
HAS_SUBSCRIBER
static final int HAS_SUBSCRIBER
- See Also:
- Constant Field Values
-
ABANDONED
static final int ABANDONED
- See Also:
- Constant Field Values
-
ABANDONED_HAS_SUBSCRIBER
static final int ABANDONED_HAS_SUBSCRIBER
- See Also:
- Constant Field Values
-
evictOnce
final java.util.concurrent.atomic.AtomicBoolean evictOnce
-
-
Constructor Detail
-
State
State(int bufferSize, FlowableGroupBy.GroupBySubscriber<?,K,T> parent, K key, boolean delayError)
-
-
Method Detail
-
request
public void request(long n)
- Specified by:
request
in interfaceorg.reactivestreams.Subscription
-
cancel
public void cancel()
- Specified by:
cancel
in interfaceorg.reactivestreams.Subscription
-
subscribe
public void subscribe(org.reactivestreams.Subscriber<? super T> subscriber)
- Specified by:
subscribe
in interfaceorg.reactivestreams.Publisher<T>
-
onNext
public void onNext(T t)
-
onError
public void onError(java.lang.Throwable e)
-
onComplete
public void onComplete()
-
tryComplete
boolean tryComplete()
-
cancelParent
void cancelParent()
-
tryAbandon
boolean tryAbandon()
-
drain
void drain()
-
drainFused
void drainFused()
-
drainNormal
void drainNormal()
-
requestParent
void requestParent(long e)
-
cleanupQueue
void cleanupQueue(long emitted, boolean polled)
-
replenishParent
void replenishParent(long emitted, boolean polled)
-
checkTerminated
boolean checkTerminated(boolean d, boolean empty, org.reactivestreams.Subscriber<? super T> a, boolean delayError, long emitted, boolean polled)
-
requestFusion
public int requestFusion(int mode)
Description copied from interface:QueueFuseable
Request a fusion mode from the upstream.This should be called before
onSubscribe
returns.Calling this method multiple times or after
onSubscribe
finished is not allowed and may result in undefined behavior.- Specified by:
requestFusion
in interfaceQueueFuseable<T>
- Parameters:
mode
- the requested fusion mode, allowed values areQueueFuseable.SYNC
,QueueFuseable.ASYNC
,QueueFuseable.ANY
combined withQueueFuseable.BOUNDARY
(e.g.,requestFusion(SYNC | BOUNDARY)
).- Returns:
- the established fusion mode:
QueueFuseable.NONE
,QueueFuseable.SYNC
,QueueFuseable.ASYNC
.
-
tryReplenish
void tryReplenish()
-
poll
@Nullable public T poll()
Description copied from interface:SimpleQueue
Tries to dequeue a value (non-null) or returns null if the queue is empty.If the producer uses
SimpleQueue.offer(Object, Object)
and when polling in pairs, if the first poll() returns a non-null item, the second poll() is guaranteed to return a non-null item as well.- Specified by:
poll
in interfaceSimpleQueue<T>
- Returns:
- the item or null to indicate an empty queue
-
isEmpty
public boolean isEmpty()
Description copied from interface:SimpleQueue
Returns true if the queue is empty.Note however that due to potential fused functions in
SimpleQueue.poll()
it is possible this method returns false but then poll() returns null because the fused function swallowed the available item(s).- Specified by:
isEmpty
in interfaceSimpleQueue<T>
- Returns:
- true if the queue is empty
-
clear
public void clear()
Description copied from interface:SimpleQueue
Removes all enqueued items from this queue.- Specified by:
clear
in interfaceSimpleQueue<T>
-
-