io.servicetalk.concurrent.api.internal

Class SubscribableSingle<T>

java.lang.Object

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

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

Type Parameters:

T - Type of result of this SubscribableSingle.

All Implemented Interfaces:

SingleSource<T>

Direct Known Subclasses:

SourceWrappers.SingleSource

public abstract class SubscribableSingle<T>
extends Single<T>
implements SingleSource<T>

A Single that is also a SingleSource and hence can be subscribed.

Typically, this will be used to implement a Single that does not require an additional allocation when converting to a SingleSource via SourceAdapters.toSource(Single).

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
SubscribableSingle()

Method Summary

Modifier and Type	Method and Description
void	subscribe(SingleSource.Subscriber<? super T> subscriber) Subscribe for the result of this SingleSource.

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

SubscribableSingle

public SubscribableSingle()

Method Detail

subscribe

public final void subscribe(SingleSource.Subscriber<? super T> subscriber)

Description copied from interface: SingleSource

Subscribe for the result of this SingleSource.

Specified by:

subscribe in interface SingleSource<T>

Parameters:

subscriber - to subscribe for the result.

See Also:

PublisherSource.subscribe(PublisherSource.Subscriber)