java.lang.Runnable
, org.reactivestreams.Subscriber<T>
public abstract class AsyncSubscriber<T> extends java.lang.Object implements org.reactivestreams.Subscriber<T>, java.lang.Runnable
Modifier | Constructor | Description |
---|---|---|
protected |
AsyncSubscriber(java.util.concurrent.Executor executor) |
Modifier and Type | Method | Description |
---|---|---|
void |
onComplete() |
|
void |
onError(java.lang.Throwable t) |
|
void |
onNext(T element) |
|
void |
onSubscribe(org.reactivestreams.Subscription s) |
|
void |
run() |
|
protected void |
whenComplete() |
|
protected void |
whenError(java.lang.Throwable error) |
|
protected abstract boolean |
whenNext(T element) |
protected AsyncSubscriber(java.util.concurrent.Executor executor)
protected void whenComplete()
protected void whenError(java.lang.Throwable error)
public final void onSubscribe(org.reactivestreams.Subscription s)
onSubscribe
in interface org.reactivestreams.Subscriber<T>
public final void onNext(T element)
onNext
in interface org.reactivestreams.Subscriber<T>
public final void onError(java.lang.Throwable t)
onError
in interface org.reactivestreams.Subscriber<T>
public final void onComplete()
onComplete
in interface org.reactivestreams.Subscriber<T>
public final void run()
run
in interface java.lang.Runnable