Class ObservableGroupBy.State<T,K>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.operators.observable.ObservableGroupBy.State<T,K>
- All Implemented Interfaces:
ObservableSource<T>
,Disposable
,Serializable
- Enclosing class:
ObservableGroupBy<T,
K, V>
static final class ObservableGroupBy.State<T,K>
extends AtomicInteger
implements Disposable, ObservableSource<T>
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) static final int
(package private) static final int
(package private) final AtomicReference
<Observer<? super T>> (package private) final AtomicBoolean
(package private) final boolean
(package private) boolean
(package private) Throwable
(package private) static final int
(package private) static final int
(package private) final K
(package private) final AtomicInteger
(package private) final ObservableGroupBy.GroupByObserver
<?, K, T> (package private) final SpscLinkedArrayQueue
<T> private static final long
-
Constructor Summary
ConstructorsConstructorDescriptionState
(int bufferSize, ObservableGroupBy.GroupByObserver<?, K, T> parent, K key, boolean delayError) -
Method Summary
Modifier and TypeMethodDescription(package private) void
(package private) boolean
checkTerminated
(boolean d, boolean empty, Observer<? super T> a, boolean delayError) void
dispose()
Dispose the resource, the operation should be idempotent.(package private) void
drain()
boolean
Returns true if this resource has been disposed.void
void
void
void
Subscribes the givenObserver
to thisObservableSource
instance.(package private) boolean
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
Methods inherited from class java.lang.Number
byteValue, shortValue
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
key
-
queue
-
parent
-
delayError
final boolean delayError -
done
volatile boolean done -
error
Throwable error -
cancelled
-
actual
-
once
-
FRESH
static final int FRESH- See Also:
-
HAS_SUBSCRIBER
static final int HAS_SUBSCRIBER- See Also:
-
ABANDONED
static final int ABANDONED- See Also:
-
ABANDONED_HAS_SUBSCRIBER
static final int ABANDONED_HAS_SUBSCRIBER- See Also:
-
-
Constructor Details
-
State
State(int bufferSize, ObservableGroupBy.GroupByObserver<?, K, T> parent, K key, boolean delayError)
-
-
Method Details
-
dispose
public void dispose()Description copied from interface:Disposable
Dispose the resource, the operation should be idempotent.- Specified by:
dispose
in interfaceDisposable
-
isDisposed
public boolean isDisposed()Description copied from interface:Disposable
Returns true if this resource has been disposed.- Specified by:
isDisposed
in interfaceDisposable
- Returns:
- true if this resource has been disposed
-
subscribe
Description copied from interface:ObservableSource
Subscribes the givenObserver
to thisObservableSource
instance.- Specified by:
subscribe
in interfaceObservableSource<T>
- Parameters:
observer
- theObserver
, notnull
-
onNext
-
onError
-
onComplete
public void onComplete() -
drain
void drain() -
cancelParent
void cancelParent() -
tryAbandon
boolean tryAbandon() -
checkTerminated
-