hu.akarnokd.rxjava2.internal.subscribers

Class QueueDrainSubscriber<T,U,V>

java.lang.Object

hu.akarnokd.rxjava2.internal.subscribers.QueueDrainSubscriber<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:

QueueDrain<U,V>, org.reactivestreams.Subscriber<T>

public abstract class QueueDrainSubscriber<T,U,V>
extends java.lang.Object
implements org.reactivestreams.Subscriber<T>, QueueDrain<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 and Description
protected org.reactivestreams.Subscriber<? super V>	actual
protected boolean	cancelled
protected boolean	done
protected java.lang.Throwable	error
protected java.util.Queue<U>	queue

Constructor Summary

Constructors

Constructor and Description
QueueDrainSubscriber(org.reactivestreams.Subscriber<? super V> actual, java.util.Queue<U> queue)

Method Summary

Modifier and Type	Method and Description
boolean	cancelled()
boolean	done()
void	drain(boolean delayError)
boolean	enter()
java.lang.Throwable	error()
boolean	fastEnter()
protected void	fastpathEmit(U value, boolean delayError)
protected void	fastpathEmitMax(U value, boolean delayError, Disposable dispose)
protected void	fastpathOrderedEmit(U value, boolean delayError) Makes sure the fast-path emits in order.
protected void	fastpathOrderedEmitMax(U value, boolean delayError, Disposable dispose)
int	leave(int m) Adds m to the wip counter.
long	produced(long n)
long	requested()
void	requested(long n)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onError, onNext, onSubscribe

Methods inherited from interface hu.akarnokd.rxjava2.internal.util.QueueDrain

accept

Field Detail

actual

protected final org.reactivestreams.Subscriber<? super V> actual

queue

protected final java.util.Queue<U> queue

cancelled

protected volatile boolean cancelled

done

protected volatile boolean done

error

protected java.lang.Throwable error

Constructor Detail

QueueDrainSubscriber

public QueueDrainSubscriber(org.reactivestreams.Subscriber<? super V> actual,
                            java.util.Queue<U> queue)

Method Detail

cancelled

public final boolean cancelled()

Specified by:

cancelled in interface QueueDrain<U,V>

done

public final boolean done()

Specified by:

done in interface QueueDrain<U,V>

enter

public final boolean enter()

Specified by:

enter in interface QueueDrain<U,V>

fastEnter

public final boolean fastEnter()

fastpathEmit

protected final void fastpathEmit(U value,
                                  boolean delayError)

fastpathEmitMax

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

fastpathOrderedEmitMax

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

fastpathOrderedEmit

protected final void fastpathOrderedEmit(U value,
                                         boolean delayError)

Makes sure the fast-path emits in order.

Parameters:

value -

delayError -

error

public final java.lang.Throwable error()

Specified by:

error in interface QueueDrain<U,V>

leave

public final int leave(int m)

Description copied from interface: QueueDrain

Adds m to the wip counter.

Specified by:

leave in interface QueueDrain<U,V>

Parameters:

m - the value to add

Returns:

the current value after adding m

requested

public final long requested()

Specified by:

requested in interface QueueDrain<U,V>

produced

public final long produced(long n)

Specified by:

produced in interface QueueDrain<U,V>

requested

public final void requested(long n)

drain

public void drain(boolean delayError)