io.servicetalk.concurrent.api

Class TestCollectingCompletableSubscriber

java.lang.Object

io.servicetalk.concurrent.api.TestCollectingCompletableSubscriber

All Implemented Interfaces:

CompletableSource.Subscriber

public final class TestCollectingCompletableSubscriber
extends java.lang.Object
implements CompletableSource.Subscriber

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

Constructor Summary

Constructors

Constructor and Description
TestCollectingCompletableSubscriber()

Method Summary

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

TestCollectingCompletableSubscriber

public TestCollectingCompletableSubscriber()

Method Detail

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(java.lang.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()
                              throws java.lang.InterruptedException

Block until onSubscribe(Cancellable).

Returns:

The PublisherSource.Subscription from onSubscribe(Cancellable).

Throws:

java.lang.InterruptedException - if an interrupt occurs while blocking for waiting for onSubscribe(Cancellable).

awaitOnError

public java.lang.Throwable awaitOnError()
                                 throws java.lang.InterruptedException

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

Returns:

the exception received by onError(Throwable).

Throws:

java.lang.InterruptedException - If an interrupt occurs while blocking for the terminal event.

awaitOnComplete

public void awaitOnComplete()
                     throws java.lang.InterruptedException

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

Throws:

java.lang.InterruptedException - If an interrupt occurs while blocking for the terminal event.

pollTerminal

public boolean pollTerminal(long timeout,
                            java.util.concurrent.TimeUnit unit)
                     throws java.lang.InterruptedException

Block for a terminal event.

Parameters:

timeout - The duration of time to wait.

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

Returns:

true if a terminal event has been received before the timeout duration.

Throws:

java.lang.InterruptedException - If an interrupt occurs while blocking for the terminal event.