Package io.servicetalk.concurrent

Interface PublisherSource.Subscriber<T>

Type Parameters:

T - Type of items received by this Subscriber.

All Known Subinterfaces:

PublisherSource.Processor<T,R>

All Known Implementing Classes:

CancelImmediatelySubscriber, ConcurrentTerminalSubscriber, LatestValueSubscriber, TestPublisherSubscriber

Enclosing interface:

PublisherSource<T>

public static interface PublisherSource.Subscriber<T>

A subscriber of result(s) produced by a PublisherSource.

This is a replica of the APIs provided by Reactive Streams and follows the Reactive Streams specifications. All implementations of this Subscriber adhere to the rules as specified for a Reactive Streams Subscriber in Section 2 of the specifications.

Method Summary

Modifier and Type	Method	Description
void	onComplete()	Callback to signal completion of the PublisherSource for this Subscriber.
void	onError(Throwable t)	Callback to receive an error for this Subscriber.
void	onNext(T t)	Callback to receive a data element for this Subscriber.
void	onSubscribe(PublisherSource.Subscription subscription)	Callback to receive a PublisherSource.Subscription for this Subscriber.

Method Details

onSubscribe

void onSubscribe(PublisherSource.Subscription subscription)

Callback to receive a PublisherSource.Subscription for this Subscriber.

See Reactive Streams specifications for the rules about how and when this method will be invoked.

Parameters:

subscription - PublisherSource.Subscription for this Subscriber.

onNext

void onNext(@Nullable
 T t)

Callback to receive a data element for this Subscriber.

See Reactive Streams specifications for the rules about how and when this method will be invoked.

Parameters:

t - A data element.

onError

void onError(Throwable t)

Callback to receive an error for this Subscriber.

See Reactive Streams specifications for the rules about how and when this method will be invoked.

Parameters:

t - error for this Subscriber.

onComplete

void onComplete()

Callback to signal completion of the PublisherSource for this Subscriber.

See Reactive Streams specifications for the rules about how and when this method will be invoked.