org.reactivestreams.tck

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 and Description
protected TestEnvironment.Promise<SubscriberWhiteboxVerification.SubscriberPuppet>	puppet

Fields inherited from class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

elements, env, error, subscriber

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
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 org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

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

Methods inherited from class java.lang.Object

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

Field Detail

puppet

protected TestEnvironment.Promise<SubscriberWhiteboxVerification.SubscriberPuppet> puppet

Constructor Detail

WhiteboxSubscriberProbe

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

Method Detail

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