io.servicetalk.concurrent.api.internal

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, SpScPublisherProcessor

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

Nested Class Summary

Nested classes/interfaces inherited from interface io.servicetalk.concurrent.PublisherSource

PublisherSource.Subscriber<T>, PublisherSource.Subscription

Constructor Summary

Constructors

Constructor and Description
SubscribablePublisher()

Method Summary

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

Methods inherited from class io.servicetalk.concurrent.api.Publisher

afterCancel, afterFinally, afterOnComplete, afterOnError, afterOnNext, afterOnSubscribe, afterRequest, afterSubscriber, afterSubscription, beforeCancel, beforeFinally, beforeOnComplete, beforeOnError, beforeOnNext, beforeOnSubscribe, beforeRequest, beforeSubscriber, beforeSubscription, collect, concat, concat, concat, defer, empty, failed, filter, firstOrElse, firstOrError, flatMapCompletable, flatMapCompletable, flatMapCompletableDelayError, flatMapCompletableDelayError, flatMapConcatIterable, flatMapMergeSingle, flatMapMergeSingle, flatMapMergeSingleDelayError, flatMapMergeSingleDelayError, forEach, from, from, fromBlockingIterable, fromInputStream, fromIterable, groupBy, groupBy, groupToMany, groupToMany, handleSubscribe, idleTimeout, idleTimeout, idleTimeout, idleTimeout, ignoreElements, liftAsync, liftSync, liftSyncToSingle, map, multicastToExactly, multicastToExactly, never, publishAndSubscribeOn, publishAndSubscribeOnOverride, publishOn, publishOnOverride, recoverWith, repeat, repeatWhen, retry, retryWhen, subscribeInternal, subscribeOn, subscribeOnOverride, subscribeShareContext, takeAtMost, takeUntil, takeWhile, toCompletionStage, toCompletionStage, toFuture, toFuture, toInputStream, toInputStream, toIterable, toIterable, whenCancel, whenFinally, whenOnComplete, whenOnError, whenOnNext, whenOnSubscribe, whenRequest

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SubscribablePublisher

public SubscribablePublisher()

Method Detail

subscribe

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

Description copied from interface: PublisherSource

Subscribe for the result(s) of this PublisherSource.

Specified by:

subscribe in interface PublisherSource<T>

Parameters:

subscriber - to subscribe for the result.