Package io.servicetalk.concurrent.api

Class TestSingle<T>

java.lang.Object

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

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

Type Parameters:

T - Type of the result of this TestSingle.

All Implemented Interfaces:

SingleSource<T>

public final class TestSingle<T>
extends Single<T>
implements SingleSource<T>

A Single & SingleSource whose outgoing signals to its SingleSource.Subscribers can be controlled.

Behavior beyond simply delegating signals to the SingleSource.Subscriber is accomplished by a Function<Subscriber<? super T>, Subscriber<? super T>>. This Function is invoked for every subscribe(Subscriber) invocation, and the result is used as the delegate for subsequent onSubscribe(Cancellable), onSuccess(Object), and onError(Throwable) calls. See TestSingle.Builder for more information.

Defaults

• Allows sequential but not concurrent subscribers.
• Sends onSubscribe(Cancellable) automatically when subscribed to.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestSingle.Builder<T>	Allows for creating TestSingles with non-default settings.

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

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

Constructor Summary

Constructors

Constructor	Description
TestSingle()	Create a TestSingle with the defaults.

Method Summary

Modifier and Type	Method	Description
protected void	handleSubscribe(SingleSource.Subscriber<? super T> subscriber)	Handles a subscriber to this Single.
boolean	isSubscribed()	Returns true if this TestSingle has been subscribed to, false otherwise.
void	onError(java.lang.Throwable t)	Delivers the Throwable t to the SingleSource.Subscriber.
void	onSubscribe(Cancellable cancellable)	Delivers the Cancellable to the SingleSource.Subscriber's SingleSource.Subscriber.onSubscribe(Cancellable).
void	onSuccess(T result)	Delivers the result to the SingleSource.Subscriber.
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, 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

Methods inherited from class java.lang.Object

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

Constructor Detail

TestSingle

public TestSingle()

Create a TestSingle with the defaults. See Defaults section of class javadoc.

Method Detail

isSubscribed

public boolean isSubscribed()

Returns true if this TestSingle has been subscribed to, false otherwise.

Returns:

true if this TestSingle has been subscribed to, false otherwise.

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.

subscribe

public 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)

onSubscribe

public void onSubscribe(Cancellable cancellable)

Delivers the Cancellable to the SingleSource.Subscriber's SingleSource.Subscriber.onSubscribe(Cancellable).

In the case of auto-on-subscribe, the delegating Cancellable sent to the SingleSource.Subscriber by the auto-on-subscribe will switch to cancellable.

Parameters:

cancellable - the Cancellable

onSuccess

public void onSuccess(@Nullable
                      T result)

Delivers the result to the SingleSource.Subscriber.

Parameters:

result - the result to deliver.

See Also:

SingleSource.Subscriber.onSuccess(Object)

onError

public void onError(java.lang.Throwable t)

Delivers the Throwable t to the SingleSource.Subscriber.

Parameters:

t - the error to deliver.

See Also:

SingleSource.Subscriber.onError(Throwable)