Interface Subscriber<T>

Type Parameters:

T - the type of element signaled

All Known Subinterfaces:

Processor<T,R>

All Known Implementing Classes:

AsyncSubscriber, FlowAdapters.ReactiveToFlowProcessor, FlowAdapters.ReactiveToFlowSubscriber, IdentityProcessorVerification.ManualSubscriberWithErrorCollection, SubscriberWhiteboxVerification.BlackboxSubscriberProxy, SyncSubscriber, TestEnvironment.BlackholeSubscriberWithSubscriptionSupport, TestEnvironment.ManualSubscriber, TestEnvironment.ManualSubscriberWithSubscriptionSupport, TestEnvironment.TestSubscriber

public interface Subscriber<T>

Will receive call to onSubscribe(Subscription) once after passing an instance of Subscriber to Publisher.subscribe(Subscriber).

No further notifications will be received until Subscription.request(long) is called.

After signaling demand:

• One or more invocations of onNext(Object) up to the maximum number defined by Subscription.request(long)
• Single invocation of onError(Throwable) or onComplete() which signals a terminal state after which no further events will be sent.

Demand can be signaled via Subscription.request(long) whenever the Subscriber instance is capable of handling more.

Method Summary

Modifier and Type	Method	Description
void	onComplete()	Successful terminal state.
void	onError(Throwable t)	Failed terminal state.
void	onNext(T t)	Data notification sent by the Publisher in response to requests to Subscription.request(long).
void	onSubscribe(Subscription s)	Invoked after calling Publisher.subscribe(Subscriber).

Method Details

onSubscribe

void onSubscribe(Subscription s)

Invoked after calling Publisher.subscribe(Subscriber).

No data will start flowing until Subscription.request(long) is invoked.

It is the responsibility of this Subscriber instance to call Subscription.request(long) whenever more data is wanted.

The Publisher will send notifications only in response to Subscription.request(long).

Parameters:

s - the Subscription that allows requesting data via Subscription.request(long)

onNext

void onNext(T t)

Data notification sent by the Publisher in response to requests to Subscription.request(long).

Parameters:

t - the element signaled

onError

void onError(Throwable t)

Failed terminal state.

No further events will be sent even if Subscription.request(long) is invoked again.

Parameters:

t - the throwable signaled

onComplete

void onComplete()

Successful terminal state.

No further events will be sent even if Subscription.request(long) is invoked again.