hu.akarnokd.rxjava2.internal.subscribers.nbp

Class NbpQueueDrainSubscriber<T,U,V>

java.lang.Object

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

NbpQueueDrain<U,V>, NbpObservable.NbpSubscriber<T>

public abstract class NbpQueueDrainSubscriber<T,U,V>
extends java.lang.Object
implements NbpObservable.NbpSubscriber<T>, NbpQueueDrain<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 NbpObservable.NbpSubscriber<? 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
NbpQueueDrainSubscriber(NbpObservable.NbpSubscriber<? super V> actual, java.util.Queue<U> queue)

Method Summary

Modifier and Type	Method and Description
boolean	cancelled()
boolean	done()
void	drain(boolean delayError, Disposable dispose)
boolean	enter()
java.lang.Throwable	error()
boolean	fastEnter()
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 hu.akarnokd.rxjava2.NbpObservable.NbpSubscriber

onComplete, onError, onNext, onSubscribe

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

accept

Field Detail

actual

protected final NbpObservable.NbpSubscriber<? 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

NbpQueueDrainSubscriber

public NbpQueueDrainSubscriber(NbpObservable.NbpSubscriber<? super V> actual,
                               java.util.Queue<U> queue)

Method Detail

cancelled

public final boolean cancelled()

Specified by:

cancelled in interface NbpQueueDrain<U,V>

done

public final boolean done()

Specified by:

done in interface NbpQueueDrain<U,V>

enter

public final boolean enter()

Specified by:

enter in interface NbpQueueDrain<U,V>

fastEnter

public final boolean fastEnter()

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 -

delayError -

error

public final java.lang.Throwable error()

Specified by:

error in interface NbpQueueDrain<U,V>

leave

public final int leave(int m)

Description copied from interface: NbpQueueDrain

Adds m to the wip counter.

Specified by:

leave in interface NbpQueueDrain<U,V>

Parameters:

m - the value to add

Returns:

the wip value after adding the value

drain

public void drain(boolean delayError,
                  Disposable dispose)