io.servicetalk.http.router.jersey.internal

Class SourceWrappers.SingleSource<T>

java.lang.Object

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

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

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

Type Parameters:

T - Type of items emitted.

All Implemented Interfaces:

SingleSource<T>, javax.xml.transform.Source

Enclosing class:

SourceWrappers

public static final class SourceWrappers.SingleSource<T>
extends SubscribableSingle<T>
implements javax.xml.transform.Source

A Single that is also a Source.

Nested Class Summary

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

SingleSource.Processor<T,R>, SingleSource.Subscriber<T>

Constructor Summary

Constructors

Constructor and Description
SingleSource(Single<T> original) Creates a new SourceWrappers.SingleSource instance.

Method Summary

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

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

subscribe

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

afterCancel, afterFinally, afterOnError, afterOnSubscribe, afterOnSuccess, afterSubscriber, beforeCancel, beforeFinally, beforeOnError, beforeOnSubscribe, beforeOnSuccess, beforeSubscriber, collectUnordered, collectUnordered, collectUnordered, collectUnordered, collectUnorderedDelayError, collectUnorderedDelayError, collectUnorderedDelayError, collectUnorderedDelayError, concat, concat, concat, defer, failed, flatMap, flatMapCompletable, flatMapPublisher, fromCallable, fromFuture, fromStage, fromSupplier, idleTimeout, idleTimeout, idleTimeout, idleTimeout, ignoreElement, liftAsync, liftSync, map, never, publishAndSubscribeOn, publishAndSubscribeOnOverride, publishOn, publishOnOverride, recoverWith, repeat, repeatWhen, retry, retryWhen, subscribe, subscribeInternal, subscribeOn, subscribeOnOverride, subscribeShareContext, succeeded, toCompletable, toCompletionStage, toFuture, toPublisher, whenCancel, whenFinally, whenOnError, whenOnSubscribe, whenOnSuccess, whenSubscriber

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleSource

public SingleSource(Single<T> original)

Creates a new SourceWrappers.SingleSource instance.

Parameters:

original - the original Single to wrap.

Method Detail

handleSubscribe

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

Description copied from class: Single

Handles a subscriber to this Single.

Specified by:

handleSubscribe in class Single<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