hu.akarnokd.rxjava2.internal.util

Interface NbpQueueDrain<T,U>

All Known Implementing Classes:

NbpQueueDrainSubscriber

public interface NbpQueueDrain<T,U>

Method Summary

Modifier and Type	Method and Description
void	accept(NbpObservable.NbpSubscriber<? super U> a, T v) Accept the value and return true if forwarded.
boolean	cancelled()
boolean	done()
boolean	enter()
java.lang.Throwable	error()
int	leave(int m) Adds m to the wip counter.

Method Detail

cancelled

boolean cancelled()

done

boolean done()

error

java.lang.Throwable error()

enter

boolean enter()

leave

int leave(int m)

Adds m to the wip counter.

Parameters:

m - the value to add

Returns:

the wip value after adding the value

accept

void accept(NbpObservable.NbpSubscriber<? super U> a,
            T v)

Accept the value and return true if forwarded.

Parameters:

a - the subscriber to deliver values to

v - the value to deliver