Package io.servicetalk.concurrent.test.internal

Class TestSingleSubscriber<T>

java.lang.Object

io.servicetalk.concurrent.test.internal.TestSingleSubscriber<T>

Type Parameters:

T - The type of data in onSuccess(Object).

All Implemented Interfaces:

SingleSource.Subscriber<T>

public final class TestSingleSubscriber<T>
extends Object
implements SingleSource.Subscriber<T>

A SingleSource.Subscriber that enqueues signals and provides blocking methods to consume them.

Constructor Summary

Constructors

Constructor	Description
TestSingleSubscriber()

Method Summary

Modifier and Type	Method	Description
Throwable	awaitOnError()	Block until a terminal signal is received, throws if onSuccess(Object) and returns normally if onError(Throwable).
T	awaitOnSuccess()	Block until a terminal signal is received, throws if onError(Throwable) and returns normally if onSuccess(Object).
Cancellable	awaitSubscription()	Block until onSubscribe(Cancellable).
void	onError(Throwable t)	Failed terminal state.
void	onSubscribe(Cancellable cancellable)	Called when the associated SingleSource is subscribed via SingleSource.subscribe(Subscriber).
void	onSuccess(T result)	Success terminal state.
Supplier<Throwable>	pollTerminal(long timeout, TimeUnit unit)	Block for a terminal event.

Methods inherited from class java.lang.Object

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

Constructor Details

TestSingleSubscriber

public TestSingleSubscriber()

Method Details

onSubscribe

public void onSubscribe(Cancellable cancellable)

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)

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(Throwable t)

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.

awaitSubscription

public Cancellable awaitSubscription()

Block until onSubscribe(Cancellable).

Returns:

The PublisherSource.Subscription from onSubscribe(Cancellable).

awaitOnError

public Throwable awaitOnError()

Block until a terminal signal is received, throws if onSuccess(Object) and returns normally if onError(Throwable).

Returns:

the exception received by onError(Throwable).

awaitOnSuccess

@Nullable
public T awaitOnSuccess()

Block until a terminal signal is received, throws if onError(Throwable) and returns normally if onSuccess(Object).

Returns:

The value delivered to onSuccess(Object).

pollTerminal

@Nullable
public Supplier<Throwable> pollTerminal(long timeout,
 TimeUnit unit)

Block for a terminal event.

Parameters:

timeout - The duration of time to wait.

unit - The unit of time to apply to the duration.

Returns:

null if a the timeout expires before a terminal event is received. A non-null Supplier that returns null if onSuccess(Object), or the Throwable from onError(Throwable).