Package io.servicetalk.concurrent.test.internal

Class TestCompletableSubscriber

java.lang.Object

io.servicetalk.concurrent.test.internal.TestCompletableSubscriber

All Implemented Interfaces:

CompletableSource.Subscriber

public final class TestCompletableSubscriber
extends Object
implements CompletableSource.Subscriber

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

Constructor Summary

Constructors

Constructor	Description
TestCompletableSubscriber()

Method Summary

Modifier and Type	Method	Description
void	awaitOnComplete()	Block until a terminal signal is received, throws if onError(Throwable) and returns normally if onComplete().
Throwable	awaitOnError()	Block until a terminal signal is received, throws if onComplete() and returns normally if onError(Throwable).
Cancellable	awaitSubscription()	Block until onSubscribe(Cancellable).
void	onComplete()	Success terminal state.
void	onError(Throwable t)	Failed terminal state.
void	onSubscribe(Cancellable cancellable)	Called when the associated CompletableSource is subscribed via CompletableSource.subscribe(Subscriber).
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

TestCompletableSubscriber

public TestCompletableSubscriber()

Method Details

onSubscribe

public void onSubscribe(Cancellable cancellable)

Description copied from interface: CompletableSource.Subscriber

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

Specified by:

onSubscribe in interface CompletableSource.Subscriber

Parameters:

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

onComplete

public void onComplete()

Description copied from interface: CompletableSource.Subscriber

Success terminal state.

No further events will be sent.

Specified by:

onComplete in interface CompletableSource.Subscriber

onError

public void onError(Throwable t)

Description copied from interface: CompletableSource.Subscriber

Failed terminal state.

No further events will be sent.

Specified by:

onError in interface CompletableSource.Subscriber

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 onComplete() and returns normally if onError(Throwable).

Returns:

the exception received by onError(Throwable).

awaitOnComplete

public void awaitOnComplete()

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

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 onComplete(), or the Throwable from onError(Throwable).