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
ASingle
that 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.SingleSource
instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.String
getSystemId()
protected void
handleSubscribe(SingleSource.Subscriber<? super T> subscriber)
Handles a subscriber to thisSingle
.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, 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.SingleSource
instance.- Parameters:
original
- the originalSingle
to wrap.
-
-
Method Detail
-
handleSubscribe
protected void handleSubscribe(SingleSource.Subscriber<? super T> subscriber)
Description copied from class:Single
Handles a subscriber to thisSingle
.- Specified by:
handleSubscribe
in classSingle<T>
- Parameters:
subscriber
- the subscriber.
-
setSystemId
public void setSystemId(java.lang.String systemId)
- Specified by:
setSystemId
in interfacejavax.xml.transform.Source
-
getSystemId
@Nullable public java.lang.String getSystemId()
- Specified by:
getSystemId
in interfacejavax.xml.transform.Source
-
-