com.github.davidmoten.util

Class DrainerAsyncBiased<T>

java.lang.Object

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

Type Parameters:

T -

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, rx.Producer producer)
void	onCompleted()
void	onError(Throwable e)
void	onNext(T t)
void	request(long n)

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,
                               rx.Producer producer)

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>