hu.akarnokd.rxjava2.internal.util

Interface QueueDrain<T,U>

All Known Implementing Classes:

QueueDrainSubscriber

public interface QueueDrain<T,U>

Method Summary

Modifier and Type	Method and Description
boolean	accept(org.reactivestreams.Subscriber<? 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.
long	produced(long n)
long	requested()

Method Detail

cancelled

boolean cancelled()

done

boolean done()

error

java.lang.Throwable error()

enter

boolean enter()

requested

long requested()

produced

long produced(long n)

leave

int leave(int m)

Adds m to the wip counter.

Parameters:

m - the value to add

Returns:

the current value after adding m

accept

boolean accept(org.reactivestreams.Subscriber<? super U> a,
               T v)

Accept the value and return true if forwarded.

Parameters:

a - the subscriber

v - the value

Returns:

true if the value was delivered