Package io.servicetalk.http.router.jersey.internal

Class SourceWrappers.PublisherSource<T>

java.lang.Object

io.servicetalk.concurrent.api.Publisher<T>

io.servicetalk.concurrent.api.internal.SubscribablePublisher<T>

io.servicetalk.http.router.jersey.internal.SourceWrappers.PublisherSource<T>

Type Parameters:

T - Type of items emitted.

All Implemented Interfaces:

PublisherSource<T>, Source

Enclosing class:

SourceWrappers

public static final class SourceWrappers.PublisherSource<T>
extends SubscribablePublisher<T>
implements Source

A Publisher that is also a Source.

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
PublisherSource(Publisher<T> original)	Creates a new SourceWrappers.PublisherSource instance.

Method Summary

Modifier and Type	Method	Description
String	getSystemId()
protected void	handleSubscribe(PublisherSource.Subscriber<? super T> subscriber)	Handles a subscriber to this Publisher.
void	setSystemId(String systemId)

Methods inherited from class io.servicetalk.concurrent.api.internal.SubscribablePublisher

subscribe

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, firstAndTail, 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, fromInputStream, fromIterable, groupBy, groupBy, groupBy, groupToMany, groupToMany, 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

Methods inherited from interface javax.xml.transform.Source

isEmpty

Constructor Details

PublisherSource

public PublisherSource(Publisher<T> original)

Creates a new SourceWrappers.PublisherSource instance.

Parameters:

original - the original Publisher to wrap.

Method Details

handleSubscribe

protected void handleSubscribe(PublisherSource.Subscriber<? super T> subscriber)

Description copied from class: Publisher

Handles a subscriber to this Publisher.

Specified by:

handleSubscribe in class Publisher<T>

Parameters:

subscriber - the subscriber.

setSystemId

public void setSystemId(String systemId)

Specified by:

setSystemId in interface Source

getSystemId

@Nullable
public String getSystemId()

Specified by:

getSystemId in interface Source