Package io.servicetalk.concurrent

Interface PublisherSource<T>

Type Parameters:

T - Type of the items emitted by this PublisherSource.

All Known Subinterfaces:

PublisherSource.Processor<T,R>

All Known Implementing Classes:

GroupedPublisher, SourceWrappers.PublisherSource, SubscribablePublisher

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface PublisherSource<T>

An asynchronous computation that emits zero or more items to its PublisherSource.Subscriber and may or may not terminate successfully or with an error.

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

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	PublisherSource.Processor<T,R>	A PublisherSource.Processor represents a processing stage that is both a PublisherSource and a PublisherSource.Subscriber and obeys the contracts of both.
static interface	PublisherSource.Subscriber<T>	A subscriber of result(s) produced by a PublisherSource.
static interface	PublisherSource.Subscription	A subscription to control the signals emitted from a PublisherSource to a PublisherSource.Subscriber.

Method Summary

Modifier and Type	Method	Description
void	subscribe(PublisherSource.Subscriber<? super T> subscriber)	Subscribe for the result(s) of this PublisherSource.

Method Details

subscribe

void subscribe(PublisherSource.Subscriber<? super T> subscriber)

Subscribe for the result(s) of this PublisherSource.

Parameters:

subscriber - to subscribe for the result.