Class Publisher<T>

  • Type Parameters:
    T - Type of items emitted.
    Direct Known Subclasses:
    GroupedPublisher, SubscribablePublisher, TestPublisher

    public abstract class Publisher<T>
    extends java.lang.Object
    An asynchronous computation that produces 0, 1 or more elements and may or may not terminate successfully or with an error.

    How to subscribe?

    This class does not provide a way to subscribe using a PublisherSource.Subscriber as such calls are ambiguous about the intent whether the subscribe is part of the same source (a.k.a an operator) or it is a terminal subscribe. If it is required to subscribe to a source, then a source adapter can be used to convert to a PublisherSource.