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
ASinglethat is also aSource.
-
-
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 newSourceWrappers.SingleSourceinstance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.StringgetSystemId()protected voidhandleSubscribe(SingleSource.Subscriber<? super T> subscriber)Handles a subscriber to thisSingle.voidsetSystemId(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, afterFinally, afterFinally, afterOnError, afterOnSubscribe, afterOnSuccess, afterSubscriber, amb, amb, ambWith, anyOf, anyOf, beforeCancel, beforeFinally, beforeFinally, 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, whenFinally, whenFinally, whenOnError, whenOnSubscribe, whenOnSuccess, whenSubscriber
-
-
-
-
Constructor Detail
-
SingleSource
public SingleSource(Single<T> original)
Creates a newSourceWrappers.SingleSourceinstance.- Parameters:
original- the originalSingleto wrap.
-
-
Method Detail
-
handleSubscribe
protected void handleSubscribe(SingleSource.Subscriber<? super T> subscriber)
Description copied from class:SingleHandles a subscriber to thisSingle.- Specified by:
handleSubscribein classSingle<T>- Parameters:
subscriber- the subscriber.
-
setSystemId
public void setSystemId(java.lang.String systemId)
- Specified by:
setSystemIdin interfacejavax.xml.transform.Source
-
getSystemId
@Nullable public java.lang.String getSystemId()
- Specified by:
getSystemIdin interfacejavax.xml.transform.Source
-
-