public interface SubscriberListener<T>
Subscriber
.Modifier and Type | Interface and Description |
---|---|
static class |
SubscriberListener.NotifyingSubscriber<T> |
Modifier and Type | Method and Description |
---|---|
default void |
subscriberOnComplete()
Invoked before
Subscriber#onComplete() |
default void |
subscriberOnError(Throwable t)
Invoked before
Subscriber#onError(Throwable) |
default void |
subscriberOnNext(T t)
Invoked before
Subscriber#onNext(Object) |
default void |
subscriptionCancel()
Invoked before
Subscription#cancel() |
static <T> <any> |
wrap(<any> delegate,
SubscriberListener<? super T> listener)
Wrap a
Subscriber with a new one that will notify a SubscriberListener of important events occurring. |
default void subscriberOnNext(T t)
Subscriber#onNext(Object)
default void subscriberOnComplete()
Subscriber#onComplete()
default void subscriberOnError(Throwable t)
Subscriber#onError(Throwable)
default void subscriptionCancel()
Subscription#cancel()
static <T> <any> wrap(<any> delegate, SubscriberListener<? super T> listener)
Subscriber
with a new one that will notify a SubscriberListener
of important events occurring.Copyright © 2022. All rights reserved.