com.github.davidmoten.rx.util

Class DrainerAsyncBiased<T>

java.lang.Object

com.github.davidmoten.rx.util.DrainerAsyncBiased<T>

Type Parameters:

T - type of the items being queued and emitted by this drainer

All Implemented Interfaces:

Drainer<T>, rx.Observer<T>, rx.Producer

public class DrainerAsyncBiased<T>
extends Object
implements Drainer<T>

Optimized for when request method is called on a different thread from the Observer methods.

Method Summary

Methods

Modifier and Type	Method and Description
static <T> DrainerAsyncBiased<T>	create(Queue<Object> queue, rx.Subscription subscription, rx.Scheduler.Worker worker, rx.Subscriber<? super T> child)
void	onCompleted()
void	onError(Throwable e)
void	onNext(T t)
void	request(long n)
long	surplus() Returns the current best estimate of

Methods inherited from class java.lang.Object

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

Method Detail

create

public static <T> DrainerAsyncBiased<T> create(Queue<Object> queue,
                               rx.Subscription subscription,
                               rx.Scheduler.Worker worker,
                               rx.Subscriber<? super T> child)

request

public void request(long n)

Specified by:

request in interface rx.Producer

onNext

public void onNext(T t)

Specified by:

onNext in interface rx.Observer<T>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface rx.Observer<T>

onError

public void onError(Throwable e)

Specified by:

onError in interface rx.Observer<T>

surplus

public long surplus()

Description copied from interface: Drainer

Returns the current best estimate of

 currentExpected + numQueuedEmissions + numEmitted - totalRequested -
 

This value can then be subtracted from a request from downstream to estimate the number required from upstream.

Specified by:

surplus in interface Drainer<T>

Returns: