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

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

Methods inherited from class java.lang.Number

byteValue, shortValue

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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 interface org.reactivestreams.Subscription

cancel

public void cancel()

Specified by:

cancel in interface org.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.

Specified by:

test in interface AppendOnlyLinkedArrayList.NonThrowingPredicate<T>

Specified by:

test in interface Predicate<T>

Parameters:

o - the value

Returns:

the boolean result

emitLoop

void emitLoop()

isFull

public boolean isFull()