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
,java.io.Serializable
- Enclosing class:
- ObservableGroupBy<T,K,V>
static final class ObservableGroupBy.State<T,K> extends java.util.concurrent.atomic.AtomicInteger implements Disposable, ObservableSource<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<Observer<? 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) static int
FRESH
(package private) static int
HAS_SUBSCRIBER
(package private) K
key
(package private) java.util.concurrent.atomic.AtomicInteger
once
(package private) ObservableGroupBy.GroupByObserver<?,K,T>
parent
(package private) SpscLinkedArrayQueue<T>
queue
private static long
serialVersionUID
-
Constructor Summary
Constructors Constructor Description State(int bufferSize, ObservableGroupBy.GroupByObserver<?,K,T> parent, K key, boolean delayError)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
cancelParent()
(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
isDisposed()
Returns true if this resource has been disposed.void
onComplete()
void
onError(java.lang.Throwable e)
void
onNext(T t)
void
subscribe(Observer<? super T> observer)
Subscribes the givenObserver
to thisObservableSource
instance.(package private) boolean
tryAbandon()
-
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 ObservableGroupBy.GroupByObserver<?,K,T> parent
-
delayError
final boolean delayError
-
done
volatile boolean done
-
error
java.lang.Throwable error
-
cancelled
final java.util.concurrent.atomic.AtomicBoolean cancelled
-
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
-
-
Constructor Detail
-
State
State(int bufferSize, ObservableGroupBy.GroupByObserver<?,K,T> parent, K key, boolean delayError)
-
-
Method Detail
-
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
public void subscribe(Observer<? super T> observer)
Description copied from interface:ObservableSource
Subscribes the givenObserver
to thisObservableSource
instance.- Specified by:
subscribe
in interfaceObservableSource<T>
- Parameters:
observer
- theObserver
, notnull
-
onNext
public void onNext(T t)
-
onError
public void onError(java.lang.Throwable e)
-
onComplete
public void onComplete()
-
drain
void drain()
-
cancelParent
void cancelParent()
-
tryAbandon
boolean tryAbandon()
-
-