Class SubscriberWhiteboxVerification.BlackboxProbe<T>

java.lang.Object

org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe<T>

All Implemented Interfaces:

SubscriberWhiteboxVerification.SubscriberProbe<T>

Direct Known Subclasses:

SubscriberWhiteboxVerification.BlackboxSubscriberProxy, SubscriberWhiteboxVerification.WhiteboxSubscriberProbe

Enclosing class:

SubscriberWhiteboxVerification<T>

public static class SubscriberWhiteboxVerification.BlackboxProbe<T>
extends Object
implements SubscriberWhiteboxVerification.SubscriberProbe<T>

Field Summary

Fields

Modifier and Type	Field	Description
protected final TestEnvironment.Receptacle<T>	elements
protected final TestEnvironment	env
protected final TestEnvironment.Promise<Throwable>	error
protected final TestEnvironment.Promise<Subscriber<? super T>>	subscriber

Constructor Summary

Constructors

Constructor	Description
BlackboxProbe(TestEnvironment env, TestEnvironment.Promise<Subscriber<? super T>> subscriber)

Method Summary

Modifier and Type	Method	Description
void	expectCompletion()
void	expectCompletion(long timeoutMillis)
void	expectCompletion(long timeoutMillis, String msg)
<E extends Throwable> E	expectError(Class<E> expected)
<E extends Throwable> E	expectError(Class<E> expected, long timeoutMillis)
void	expectError(Throwable expected)
void	expectError(Throwable expected, long timeoutMillis)
<E extends Throwable> void	expectErrorWithMessage(Class<E> expected, String requiredMessagePart)
T	expectNext()
void	expectNext(T expected)
void	expectNext(T expected, long timeoutMillis)
void	expectNone()
void	expectNone(long withinMillis)
void	registerOnComplete()	Must be called by the test subscriber when it has received an `onComplete` event.
void	registerOnError(Throwable cause)	Must be called by the test subscriber when it has received an `onError` event.
void	registerOnNext(T element)	Must be called by the test subscriber when it has received an`onNext` event.
Subscriber<? super T>	sub()

Methods inherited from class Object

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

Field Details

env

protected final TestEnvironment env

subscriber

protected final TestEnvironment.Promise<Subscriber<? super T>> subscriber

elements

protected final TestEnvironment.Receptacle<T> elements

error

protected final TestEnvironment.Promise<Throwable> error

Constructor Details

BlackboxProbe

public BlackboxProbe(TestEnvironment env,
 TestEnvironment.Promise<Subscriber<? super T>> subscriber)

Method Details

registerOnNext

public void registerOnNext(T element)

Description copied from interface: SubscriberWhiteboxVerification.SubscriberProbe

Must be called by the test subscriber when it has received an`onNext` event.

Specified by:

registerOnNext in interface SubscriberWhiteboxVerification.SubscriberProbe<T>

registerOnComplete

public void registerOnComplete()

Description copied from interface: SubscriberWhiteboxVerification.SubscriberProbe

Must be called by the test subscriber when it has received an `onComplete` event.

Specified by:

registerOnComplete in interface SubscriberWhiteboxVerification.SubscriberProbe<T>

registerOnError

public void registerOnError(Throwable cause)

Description copied from interface: SubscriberWhiteboxVerification.SubscriberProbe

Must be called by the test subscriber when it has received an `onError` event.

Specified by:

registerOnError in interface SubscriberWhiteboxVerification.SubscriberProbe<T>

expectNext

public T expectNext()
             throws InterruptedException

Throws:

InterruptedException

expectNext

public void expectNext(T expected)
                throws InterruptedException

Throws:

InterruptedException

expectNext

public void expectNext(T expected,
 long timeoutMillis)
                throws InterruptedException

Throws:

InterruptedException

sub

public Subscriber<? super T> sub()

expectCompletion

public void expectCompletion()
                      throws InterruptedException

Throws:

InterruptedException

expectCompletion

public void expectCompletion(long timeoutMillis)
                      throws InterruptedException

Throws:

InterruptedException

expectCompletion

public void expectCompletion(long timeoutMillis,
 String msg)
                      throws InterruptedException

Throws:

InterruptedException

expectErrorWithMessage

public <E extends Throwable> void expectErrorWithMessage(Class<E> expected,
 String requiredMessagePart)
                                                  throws InterruptedException

Throws:

InterruptedException

expectError

public <E extends Throwable> E expectError(Class<E> expected)
                                    throws InterruptedException

Throws:

InterruptedException

expectError

public <E extends Throwable> E expectError(Class<E> expected,
 long timeoutMillis)
                                    throws InterruptedException

Throws:

InterruptedException

expectError

public void expectError(Throwable expected)
                 throws InterruptedException

Throws:

InterruptedException

expectError

public void expectError(Throwable expected,
 long timeoutMillis)
                 throws InterruptedException

Throws:

InterruptedException

expectNone

public void expectNone()
                throws InterruptedException

Throws:

InterruptedException

expectNone

public void expectNone(long withinMillis)
                throws InterruptedException

Throws:

InterruptedException