Package io.reactivex.rxjava3.internal.observers

Class QueueDrainObserver<T,U,V>

java.lang.Object

io.reactivex.rxjava3.internal.observers.QueueDrainSubscriberPad0

io.reactivex.rxjava3.internal.observers.QueueDrainSubscriberWip

io.reactivex.rxjava3.internal.observers.QueueDrainSubscriberPad2

io.reactivex.rxjava3.internal.observers.QueueDrainObserver<T,U,V>

Type Parameters:

T - the source type to which this subscriber will be subscribed

U - the value type in the queue

V - the value type the child subscriber accepts

All Implemented Interfaces:

Observer<T>, ObservableQueueDrain<U,V>

Direct Known Subclasses:

ObservableBufferExactBoundary.BufferExactBoundaryObserver, ObservableBufferTimed.BufferExactBoundedObserver, ObservableBufferTimed.BufferExactUnboundedObserver, ObservableBufferTimed.BufferSkipBoundedObserver

public abstract class QueueDrainObserver<T,U,V>
extends QueueDrainSubscriberPad2
implements Observer<T>, ObservableQueueDrain<U,V>

Abstract base class for subscribers that hold another subscriber, a queue and requires queue-drain behavior.

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	cancelled
protected boolean	done
protected Observer<? super V>	downstream
protected java.lang.Throwable	error
protected SimplePlainQueue<U>	queue

Fields inherited from class io.reactivex.rxjava3.internal.observers.QueueDrainSubscriberPad2

p10a, p11a, p12a, p13a, p14a, p15a, p1a, p2a, p3a, p4a, p5a, p6a, p7a, p8a, p9a

Fields inherited from class io.reactivex.rxjava3.internal.observers.QueueDrainSubscriberWip

wip

Fields inherited from class io.reactivex.rxjava3.internal.observers.QueueDrainSubscriberPad0

p1, p10, p11, p12, p13, p14, p15, p2, p3, p4, p5, p6, p7, p8, p9

Constructor Summary

Constructors

Constructor	Description
QueueDrainObserver(Observer<? super V> actual, SimplePlainQueue<U> queue)

Method Summary

Modifier and Type	Method	Description
void	accept(Observer<? super V> a, U v)	Accept the value and return true if forwarded.
boolean	cancelled()
boolean	done()
boolean	enter()
java.lang.Throwable	error()
protected void	fastPathEmit(U value, boolean delayError, Disposable dispose)
protected void	fastPathOrderedEmit(U value, boolean delayError, Disposable disposable)	Makes sure the fast-path emits in order.
int	leave(int m)	Adds m to the wip counter.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.reactivex.rxjava3.core.Observer

onComplete, onError, onNext, onSubscribe

Field Detail

downstream

protected final Observer<? super V> downstream

queue

protected final SimplePlainQueue<U> queue

cancelled

protected volatile boolean cancelled

done

protected volatile boolean done

error

protected java.lang.Throwable error

Constructor Detail

QueueDrainObserver

public QueueDrainObserver(Observer<? super V> actual,
                          SimplePlainQueue<U> queue)

Method Detail

cancelled

public final boolean cancelled()

Specified by:

cancelled in interface ObservableQueueDrain<T,U>

done

public final boolean done()

Specified by:

done in interface ObservableQueueDrain<T,U>

enter

public final boolean enter()

Specified by:

enter in interface ObservableQueueDrain<T,U>

fastPathEmit

protected final void fastPathEmit(U value,
                                  boolean delayError,
                                  Disposable dispose)

fastPathOrderedEmit

protected final void fastPathOrderedEmit(U value,
                                         boolean delayError,
                                         Disposable disposable)

Makes sure the fast-path emits in order.

Parameters:

value - the value to emit or queue up

delayError - if true, errors are delayed until the source has terminated

disposable - the resource to dispose if the drain terminates

error

public final java.lang.Throwable error()

Specified by:

error in interface ObservableQueueDrain<T,U>

leave

public final int leave(int m)

Description copied from interface: ObservableQueueDrain

Adds m to the wip counter.

Specified by:

leave in interface ObservableQueueDrain<T,U>

Parameters:

m - the value to add

Returns:

the wip value after adding the value

accept

public void accept(Observer<? super V> a,
                   U v)

Description copied from interface: ObservableQueueDrain

Accept the value and return true if forwarded.

Specified by:

accept in interface ObservableQueueDrain<T,U>

Parameters:

a - the subscriber to deliver values to

v - the value to deliver