Package io.servicetalk.concurrent.api

Class LegacyTestSingle<T>

java.lang.Object

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

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

All Implemented Interfaces:

SingleSource.Subscriber<T>

@Deprecated
public class LegacyTestSingle<T>
extends Single<T>
implements SingleSource.Subscriber<T>

Deprecated.

Use TestSingle instead.

Deprecated.

Constructor Summary

Constructors

Constructor	Description
LegacyTestSingle()	Deprecated.
LegacyTestSingle(boolean invokeListenerPostCancel)	Deprecated.
LegacyTestSingle(boolean invokeListenerPostCancel, boolean cacheResults)	Deprecated.
LegacyTestSingle(Executor executor, boolean invokeListenerPostCancel, boolean cacheResults)	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	handleSubscribe(SingleSource.Subscriber<? super T> subscriber)	Deprecated. Handles a subscriber to this Single.
boolean	isCancelled()	Deprecated.
void	onError(java.lang.Throwable t)	Deprecated. Failed terminal state.
void	onSubscribe(Cancellable cancellable)	Deprecated. Called when the associated SingleSource is subscribed via SingleSource.subscribe(Subscriber).
void	onSuccess(T result)	Deprecated. Success terminal state.
LegacyTestSingle<T>	verifyCancelled()	Deprecated.
LegacyTestSingle<T>	verifyListenCalled()	Deprecated.
LegacyTestSingle<T>	verifyListenCalled(int times)	Deprecated.
LegacyTestSingle<T>	verifyListenNotCalled()	Deprecated.
LegacyTestSingle<T>	verifyNotCancelled()	Deprecated.

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, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, publishAndSubscribeOn, publishAndSubscribeOnOverride, publishOn, publishOnOverride, recoverWith, repeat, repeatWhen, retry, retryWhen, subscribe, subscribeInternal, subscribeOn, subscribeOnOverride, subscribeShareContext, succeeded, timeout, timeout, timeout, timeout, toCompletable, toCompletionStage, toFuture, toPublisher, whenCancel, whenFinally, whenFinally, whenFinally, whenOnError, whenOnSubscribe, whenOnSuccess, whenSubscriber, zip, zip, zip, zip, zipWith

Methods inherited from class java.lang.Object

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

Constructor Detail

LegacyTestSingle

public LegacyTestSingle()

Deprecated.

LegacyTestSingle

public LegacyTestSingle(boolean invokeListenerPostCancel)

Deprecated.

LegacyTestSingle

public LegacyTestSingle(boolean invokeListenerPostCancel,
                        boolean cacheResults)

Deprecated.

LegacyTestSingle

public LegacyTestSingle(Executor executor,
                        boolean invokeListenerPostCancel,
                        boolean cacheResults)

Deprecated.

Method Detail

handleSubscribe

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

Deprecated.

Description copied from class: Single

Handles a subscriber to this Single.

Specified by:

handleSubscribe in class Single<T>

Parameters:

subscriber - the subscriber.

onSubscribe

public void onSubscribe(Cancellable cancellable)

Deprecated.

Description copied from interface: SingleSource.Subscriber

Called when the associated SingleSource is subscribed via SingleSource.subscribe(Subscriber).

Specified by:

onSubscribe in interface SingleSource.Subscriber<T>

Parameters:

cancellable - A Cancellable that can be used to cancel the asynchronous computation for this subscriber.

onSuccess

public void onSuccess(@Nullable
                      T result)

Deprecated.

Description copied from interface: SingleSource.Subscriber

Success terminal state.

No further events will be sent.

Specified by:

onSuccess in interface SingleSource.Subscriber<T>

Parameters:

result - of the SingleSource.

onError

public void onError(java.lang.Throwable t)

Deprecated.

Description copied from interface: SingleSource.Subscriber

Failed terminal state.

No further events will be sent.

Specified by:

onError in interface SingleSource.Subscriber<T>

Parameters:

t - the throwable signaled.

isCancelled

public boolean isCancelled()

Deprecated.

verifyListenCalled

public LegacyTestSingle<T> verifyListenCalled()

Deprecated.

verifyListenCalled

public LegacyTestSingle<T> verifyListenCalled(int times)

Deprecated.

verifyListenNotCalled

public LegacyTestSingle<T> verifyListenNotCalled()

Deprecated.

verifyCancelled

public LegacyTestSingle<T> verifyCancelled()

Deprecated.

verifyNotCancelled

public LegacyTestSingle<T> verifyNotCancelled()

Deprecated.