Package 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

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.Processor<T,R>, PublisherSource.Subscriber<T>, PublisherSource.Subscription

Constructor Summary

Constructors

Constructor	Description
SubscribablePublisher()

Method Summary

Modifier and Type	Method	Description
final 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, afterFinally, afterOnComplete, afterOnError, afterOnNext, afterOnSubscribe, afterRequest, afterSubscriber, afterSubscription, beforeCancel, beforeFinally, beforeFinally, beforeOnComplete, beforeOnError, beforeOnNext, beforeOnSubscribe, beforeRequest, beforeSubscriber, beforeSubscription, buffer, cast, collect, completableOrError, concat, concat, concat, concatPropagateCancel, defer, distinct, empty, failed, filter, firstOrElse, firstOrError, flatMapCompletable, flatMapCompletable, flatMapCompletableDelayError, flatMapCompletableDelayError, flatMapCompletableDelayError, flatMapConcatIterable, flatMapConcatSingle, flatMapConcatSingle, flatMapConcatSingleDelayError, flatMapConcatSingleDelayError, flatMapMerge, flatMapMerge, flatMapMergeDelayError, flatMapMergeDelayError, flatMapMergeDelayError, flatMapMergeSingle, flatMapMergeSingle, flatMapMergeSingleDelayError, flatMapMergeSingleDelayError, flatMapMergeSingleDelayError, forEach, from, from, from, from, fromBlockingIterable, fromInputStream, fromInputStream, fromIterable, groupBy, groupBy, groupBy, groupToMany, groupToMany, handleSubscribe, ignoreElements, liftAsync, liftSync, liftSyncToSingle, map, merge, mergeAll, mergeAll, mergeAllDelayError, mergeAllDelayError, mergeDelayError, multicast, multicast, multicast, multicast, multicast, multicast, multicastToExactly, multicastToExactly, never, ofType, onCompleteError, onErrorComplete, onErrorComplete, onErrorComplete, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, publishOn, publishOn, range, range, repeat, repeatWhen, replay, replay, replay, replay, retry, retry, retryWhen, retryWhen, scanWith, scanWith, scanWithLifetime, scanWithLifetimeMapper, scanWithMapper, setContextOnSubscribe, shareContextOnSubscribe, skipWhile, subscribeInternal, subscribeOn, subscribeOn, switchMap, switchMapDelayError, switchMapDelayError, takeAtMost, takeUntil, takeWhile, timeout, timeout, timeout, timeout, timeoutDemand, timeoutDemand, timeoutDemand, timeoutDemand, timeoutTerminal, timeoutTerminal, timeoutTerminal, timeoutTerminal, toCompletionStage, toCompletionStage, toFuture, toFuture, toInputStream, toInputStream, toIterable, toIterable, validateOutstandingDemand, validateOutstandingDemand, whenCancel, whenFinally, whenFinally, whenOnComplete, whenOnError, whenOnNext, whenOnSubscribe, whenRequest, whenSubscriber, whenSubscription

Methods inherited from class java.lang.Object

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

Constructor Details

SubscribablePublisher

public SubscribablePublisher()

Method Details

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.