Class SubscribablePublisher<T>

java.lang.Object
io.servicetalk.concurrent.api.Publisher<T>
io.servicetalk.concurrent.api.internal.SubscribablePublisher<T>
Type Parameters:
T - Type of the items emitted by this SubscribablePublisher.
All Implemented Interfaces:
PublisherSource<T>
Direct Known Subclasses:
SourceWrappers.PublisherSource

public abstract class SubscribablePublisher<T> extends Publisher<T> implements PublisherSource<T>
A Publisher that is also a PublisherSource and hence can be subscribed.

Typically, this will be used to implement a Publisher that does not require an additional allocation when converting to a PublisherSource via SourceAdapters.toSource(Publisher).

  • Constructor Details

    • SubscribablePublisher

      public SubscribablePublisher()
  • Method Details