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

Enclosing class:

SourceWrappers

public static final class SourceWrappers.SingleSource<T>
extends SubscribableSingle<T>
implements 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	Description
SingleSource(Single<T> original)	Creates a new SourceWrappers.SingleSource instance.

Method Summary

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

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

subscribe

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

afterCancel, afterFinally, afterFinally, afterFinally, afterOnError, afterOnSubscribe, afterOnSuccess, afterSubscriber, amb, amb, ambWith, anyOf, anyOf, beforeCancel, beforeFinally, beforeFinally, beforeFinally, beforeOnError, beforeOnSubscribe, beforeOnSuccess, beforeSubscriber, cache, cache, cache, cache, cast, collectUnordered, collectUnordered, collectUnordered, collectUnordered, collectUnorderedDelayError, collectUnorderedDelayError, collectUnorderedDelayError, collectUnorderedDelayError, concat, concat, concat, concat, concatDeferSubscribe, concatPropagateCancel, defer, failed, flatMap, flatMapCompletable, flatMapPublisher, fromCallable, fromFuture, fromStage, fromSupplier, ignoreElement, liftAsync, liftSync, map, never, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, publishOn, publishOn, repeat, repeat, repeatWhen, repeatWhen, retry, retryWhen, setContextOnSubscribe, shareContextOnSubscribe, subscribe, subscribeInternal, subscribeOn, subscribeOn, succeeded, timeout, timeout, timeout, timeout, toCompletable, toCompletionStage, toFuture, toPublisher, whenCancel, whenFinally, whenFinally, whenFinally, whenOnError, whenOnSubscribe, whenOnSuccess, whenSubscriber, zip, zip, zip, zip, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipWith, zipWithDelayError

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

SingleSource

public SingleSource(Single<T> original)

Creates a new SourceWrappers.SingleSource instance.

Parameters:

original - the original Single to wrap.

Method Details

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

Specified by:

setSystemId in interface Source

getSystemId

@Nullable
public String getSystemId()

Specified by:

getSystemId in interface Source