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>, javax.xml.transform.Source

Enclosing class:

SourceWrappers

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

A Publisher that is also a Source.

Nested Class Summary

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

PublisherSource.Subscriber<T>, PublisherSource.Subscription

Constructor Summary

Constructors

Constructor and Description
PublisherSource(Publisher<T> original) Creates a new SourceWrappers.PublisherSource instance.

Method Summary

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

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

subscribe

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

PublisherSource

public PublisherSource(Publisher<T> original)

Creates a new SourceWrappers.PublisherSource instance.

Parameters:

original - the original Publisher to wrap.

Method Detail

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(java.lang.String systemId)

Specified by:

setSystemId in interface javax.xml.transform.Source

getSystemId

@Nullable
public java.lang.String getSystemId()

Specified by:

getSystemId in interface javax.xml.transform.Source