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.UseTestSingle
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
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description void
handleSubscribe(SingleSource.Subscriber<? super T> subscriber)
Deprecated.Handles a subscriber to thisSingle
.boolean
isCancelled()
Deprecated.void
onError(java.lang.Throwable t)
Deprecated.Failed terminal state.void
onSubscribe(Cancellable cancellable)
Deprecated.Called when the associatedSingleSource
is subscribed viaSingleSource.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, 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
-
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 thisSingle
.- Specified by:
handleSubscribe
in classSingle<T>
- Parameters:
subscriber
- the subscriber.
-
onSubscribe
public void onSubscribe(Cancellable cancellable)
Deprecated.Description copied from interface:SingleSource.Subscriber
Called when the associatedSingleSource
is subscribed viaSingleSource.subscribe(Subscriber)
.- Specified by:
onSubscribe
in interfaceSingleSource.Subscriber<T>
- Parameters:
cancellable
- ACancellable
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 interfaceSingleSource.Subscriber<T>
- Parameters:
result
- of theSingleSource
.
-
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 interfaceSingleSource.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.
-
-