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:
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.

  • 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.