SubscriberWhiteboxVerification.SubscriberProbe<T>
SubscriberWhiteboxVerification.BlackboxSubscriberProxy
, SubscriberWhiteboxVerification.WhiteboxSubscriberProbe
public static class SubscriberWhiteboxVerification.BlackboxProbe<T> extends java.lang.Object implements SubscriberWhiteboxVerification.SubscriberProbe<T>
Modifier and Type | Field | Description |
---|---|---|
protected TestEnvironment.Receptacle<T> |
elements |
|
protected TestEnvironment |
env |
|
protected TestEnvironment.Promise<java.lang.Throwable> |
error |
|
protected TestEnvironment.Promise<org.reactivestreams.Subscriber<? super T>> |
subscriber |
Constructor | Description |
---|---|
BlackboxProbe(TestEnvironment env,
TestEnvironment.Promise<org.reactivestreams.Subscriber<? super T>> subscriber) |
Modifier and Type | Method | Description |
---|---|---|
void |
expectCompletion() |
|
void |
expectCompletion(long timeoutMillis) |
|
void |
expectCompletion(long timeoutMillis,
java.lang.String msg) |
|
<E extends java.lang.Throwable> |
expectError(java.lang.Class<E> expected) |
|
<E extends java.lang.Throwable> |
expectError(java.lang.Class<E> expected,
long timeoutMillis) |
|
void |
expectError(java.lang.Throwable expected) |
|
void |
expectError(java.lang.Throwable expected,
long timeoutMillis) |
|
<E extends java.lang.Throwable> |
expectErrorWithMessage(java.lang.Class<E> expected,
java.lang.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(java.lang.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.
|
org.reactivestreams.Subscriber<? super T> |
sub() |
protected final TestEnvironment env
protected final TestEnvironment.Promise<org.reactivestreams.Subscriber<? super T>> subscriber
protected final TestEnvironment.Receptacle<T> elements
protected final TestEnvironment.Promise<java.lang.Throwable> error
public BlackboxProbe(TestEnvironment env, TestEnvironment.Promise<org.reactivestreams.Subscriber<? super T>> subscriber)
public void registerOnNext(T element)
SubscriberWhiteboxVerification.SubscriberProbe
registerOnNext
in interface SubscriberWhiteboxVerification.SubscriberProbe<T>
public void registerOnComplete()
SubscriberWhiteboxVerification.SubscriberProbe
registerOnComplete
in interface SubscriberWhiteboxVerification.SubscriberProbe<T>
public void registerOnError(java.lang.Throwable cause)
SubscriberWhiteboxVerification.SubscriberProbe
registerOnError
in interface SubscriberWhiteboxVerification.SubscriberProbe<T>
public T expectNext() throws java.lang.InterruptedException
java.lang.InterruptedException
public void expectNext(T expected) throws java.lang.InterruptedException
java.lang.InterruptedException
public void expectNext(T expected, long timeoutMillis) throws java.lang.InterruptedException
java.lang.InterruptedException
public void expectCompletion() throws java.lang.InterruptedException
java.lang.InterruptedException
public void expectCompletion(long timeoutMillis) throws java.lang.InterruptedException
java.lang.InterruptedException
public void expectCompletion(long timeoutMillis, java.lang.String msg) throws java.lang.InterruptedException
java.lang.InterruptedException
public <E extends java.lang.Throwable> void expectErrorWithMessage(java.lang.Class<E> expected, java.lang.String requiredMessagePart) throws java.lang.InterruptedException
java.lang.InterruptedException
public <E extends java.lang.Throwable> E expectError(java.lang.Class<E> expected) throws java.lang.InterruptedException
java.lang.InterruptedException
public <E extends java.lang.Throwable> E expectError(java.lang.Class<E> expected, long timeoutMillis) throws java.lang.InterruptedException
java.lang.InterruptedException
public void expectError(java.lang.Throwable expected) throws java.lang.InterruptedException
java.lang.InterruptedException
public void expectError(java.lang.Throwable expected, long timeoutMillis) throws java.lang.InterruptedException
java.lang.InterruptedException
public void expectNone() throws java.lang.InterruptedException
java.lang.InterruptedException
public void expectNone(long withinMillis) throws java.lang.InterruptedException
java.lang.InterruptedException