Class SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T>

java.lang.Object

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

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

All Implemented Interfaces:

SubscriberWhiteboxVerification.SubscriberProbe<T>, SubscriberWhiteboxVerification.SubscriberPuppeteer

Enclosing class:

SubscriberWhiteboxVerification<T>

public static class SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T>
extends SubscriberWhiteboxVerification.BlackboxProbe<T>
implements SubscriberWhiteboxVerification.SubscriberPuppeteer

Field Summary

Fields

Modifier and Type	Field	Description
protected TestEnvironment.Promise<SubscriberWhiteboxVerification.SubscriberPuppet>	puppet

Fields inherited from class SubscriberWhiteboxVerification.BlackboxProbe

elements, env, error, subscriber

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
private SubscriberWhiteboxVerification.SubscriberPuppet	puppet()
void	registerOnSubscribe(SubscriberWhiteboxVerification.SubscriberPuppet p)	Must be called by the test subscriber when it has successfully registered a subscription inside the `onSubscribe` method.

Methods inherited from class SubscriberWhiteboxVerification.BlackboxProbe

expectCompletion, expectCompletion, expectCompletion, expectError, expectError, expectError, expectError, expectErrorWithMessage, expectNext, expectNext, expectNext, expectNone, expectNone, registerOnComplete, registerOnError, registerOnNext, sub

Methods inherited from class Object

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

Field Details

puppet

protected TestEnvironment.Promise<SubscriberWhiteboxVerification.SubscriberPuppet> puppet

Constructor Details

WhiteboxSubscriberProbe

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

Method Details

puppet

private SubscriberWhiteboxVerification.SubscriberPuppet puppet()

registerOnSubscribe

public void registerOnSubscribe(SubscriberWhiteboxVerification.SubscriberPuppet p)

Description copied from interface: SubscriberWhiteboxVerification.SubscriberPuppeteer

Must be called by the test subscriber when it has successfully registered a subscription inside the `onSubscribe` method.

Specified by:

registerOnSubscribe in interface SubscriberWhiteboxVerification.SubscriberPuppeteer