io.servicetalk.concurrent

Interface PublisherSource<T>

Type Parameters:

T - Type of the items emitted by this PublisherSource.

All Known Implementing Classes:

SourceWrappers.PublisherSource, SpScPublisherProcessor, 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 and Description
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 and Description
void	subscribe(PublisherSource.Subscriber<? super T> subscriber) Subscribe for the result(s) of this PublisherSource.

Method Detail

subscribe

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

Subscribe for the result(s) of this PublisherSource.

Parameters:

subscriber - to subscribe for the result.