Package io.reactivex.rxjava3.processors
Class BehaviorProcessor.BehaviorSubscription<T>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicLong
io.reactivex.rxjava3.processors.BehaviorProcessor.BehaviorSubscription<T>
- All Implemented Interfaces:
Predicate<Object>
,AppendOnlyLinkedArrayList.NonThrowingPredicate<Object>
,Serializable
,org.reactivestreams.Subscription
- Enclosing class:
BehaviorProcessor<T>
static final class BehaviorProcessor.BehaviorSubscription<@NonNull T>
extends AtomicLong
implements org.reactivestreams.Subscription, AppendOnlyLinkedArrayList.NonThrowingPredicate<Object>
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean
(package private) final org.reactivestreams.Subscriber
<? super T> (package private) boolean
(package private) boolean
(package private) long
(package private) boolean
(package private) AppendOnlyLinkedArrayList
<Object> private static final long
(package private) final BehaviorProcessor
<T> -
Constructor Summary
ConstructorsConstructorDescriptionBehaviorSubscription
(org.reactivestreams.Subscriber<? super @NonNull T> actual, BehaviorProcessor<@NonNull T> state) -
Method Summary
Methods inherited from class java.util.concurrent.atomic.AtomicLong
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:
-
downstream
-
state
-
next
boolean next -
emitting
boolean emitting -
queue
AppendOnlyLinkedArrayList<Object> queue -
fastPath
boolean fastPath -
cancelled
volatile boolean cancelled -
index
long index
-
-
Constructor Details
-
BehaviorSubscription
BehaviorSubscription(org.reactivestreams.Subscriber<? super @NonNull T> actual, BehaviorProcessor<@NonNull T> state)
-
-
Method Details
-
request
public void request(long n) - Specified by:
request
in interfaceorg.reactivestreams.Subscription
-
cancel
public void cancel()- Specified by:
cancel
in interfaceorg.reactivestreams.Subscription
-
emitFirst
void emitFirst() -
emitNext
-
test
Description copied from interface:Predicate
Test the given input value and return a boolean. -
emitLoop
void emitLoop() -
isFull
public boolean isFull()
-