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<java.lang.Object>
,AppendOnlyLinkedArrayList.NonThrowingPredicate<java.lang.Object>
,java.io.Serializable
,org.reactivestreams.Subscription
- Enclosing class:
- BehaviorProcessor<T>
static final class BehaviorProcessor.BehaviorSubscription<@NonNull T> extends java.util.concurrent.atomic.AtomicLong implements org.reactivestreams.Subscription, AppendOnlyLinkedArrayList.NonThrowingPredicate<java.lang.Object>
-
-
Field Summary
Fields Modifier and Type Field Description (package private) boolean
cancelled
(package private) org.reactivestreams.Subscriber<? super T>
downstream
(package private) boolean
emitting
(package private) boolean
fastPath
(package private) long
index
(package private) boolean
next
(package private) AppendOnlyLinkedArrayList<java.lang.Object>
queue
private static long
serialVersionUID
(package private) BehaviorProcessor<T>
state
-
Constructor Summary
Constructors Constructor Description BehaviorSubscription(org.reactivestreams.Subscriber<? super @NonNull T> actual, BehaviorProcessor<@NonNull T> state)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancel()
(package private) void
emitFirst()
(package private) void
emitLoop()
(package private) void
emitNext(java.lang.Object value, long stateIndex)
boolean
isFull()
void
request(long n)
boolean
test(java.lang.Object o)
Test the given input value and return a boolean.-
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
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
downstream
final org.reactivestreams.Subscriber<? super T> downstream
-
state
final BehaviorProcessor<T> state
-
next
boolean next
-
emitting
boolean emitting
-
queue
AppendOnlyLinkedArrayList<java.lang.Object> queue
-
fastPath
boolean fastPath
-
cancelled
volatile boolean cancelled
-
index
long index
-
-
Constructor Detail
-
BehaviorSubscription
BehaviorSubscription(org.reactivestreams.Subscriber<? super @NonNull T> actual, BehaviorProcessor<@NonNull T> state)
-
-
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
-
emitFirst
void emitFirst()
-
emitNext
void emitNext(java.lang.Object value, long stateIndex)
-
test
public boolean test(java.lang.Object o)
Description copied from interface:Predicate
Test the given input value and return a boolean.
-
emitLoop
void emitLoop()
-
isFull
public boolean isFull()
-
-