public final class SinkholeSubscriber<T>
extends java.lang.Object
implements org.reactivestreams.Subscriber<T>
Constructor and Description |
---|
SinkholeSubscriber(scala.concurrent.Promise<Done> whenComplete) |
Modifier and Type | Method and Description |
---|---|
void |
onComplete() |
void |
onError(java.lang.Throwable cause) |
void |
onNext(T element) |
void |
onSubscribe(org.reactivestreams.Subscription sub) |
public SinkholeSubscriber(scala.concurrent.Promise<Done> whenComplete)
public void onSubscribe(org.reactivestreams.Subscription sub)
onSubscribe
in interface org.reactivestreams.Subscriber<T>
public void onError(java.lang.Throwable cause)
onError
in interface org.reactivestreams.Subscriber<T>
public void onComplete()
onComplete
in interface org.reactivestreams.Subscriber<T>