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

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

elements, env, error, subscriber

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 java.lang.Object

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

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

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