Package org.reactivestreams.tck

Class SubscriberWhiteboxVerification.WhiteboxTestStage

java.lang.Object

org.reactivestreams.tck.TestEnvironment.ManualPublisher<T>

org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

Enclosing class:

SubscriberWhiteboxVerification<T>

public class SubscriberWhiteboxVerification.WhiteboxTestStage
extends TestEnvironment.ManualPublisher<T>

Field Summary

Fields

Modifier and Type	Field	Description
T	lastT
SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T>	probe
org.reactivestreams.Publisher<T>	pub
TestEnvironment.ManualSubscriber<T>	tees

Fields inherited from class org.reactivestreams.tck.TestEnvironment.ManualPublisher

cancelled, env, pendingDemand, requests, subscriber

Constructor Summary

Constructors

Constructor	Description
WhiteboxTestStage(TestEnvironment env)
WhiteboxTestStage(TestEnvironment env, boolean runDefaultInit)

Method Summary

Modifier and Type	Method	Description
org.reactivestreams.Publisher<T>	createHelperPublisher(long elements)
SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T>	createWhiteboxSubscriberProbe(TestEnvironment env)
T	nextT()
SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T>	probe()
SubscriberWhiteboxVerification.SubscriberPuppet	puppet()
T	signalNext()
org.reactivestreams.Subscriber<? super T>	sub()
void	verifyNoAsyncErrors()

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.TestEnvironment.ManualPublisher

expectCancelling, expectCancelling, expectExactRequest, expectExactRequest, expectNoRequest, expectNoRequest, expectRequest, expectRequest, expectRequest, isCancelled, sendCompletion, sendError, sendNext, subscribe

Field Detail

pub

public org.reactivestreams.Publisher<T> pub

tees

public TestEnvironment.ManualSubscriber<T> tees

probe

public SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> probe

lastT

public T lastT

Constructor Detail

WhiteboxTestStage

public WhiteboxTestStage(TestEnvironment env)
                  throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

WhiteboxTestStage

public WhiteboxTestStage(TestEnvironment env,
                         boolean runDefaultInit)
                  throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

Method Detail

sub

public org.reactivestreams.Subscriber<? super T> sub()

puppet

public SubscriberWhiteboxVerification.SubscriberPuppet puppet()

probe

public SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> probe()

createHelperPublisher

public org.reactivestreams.Publisher<T> createHelperPublisher(long elements)

createWhiteboxSubscriberProbe

public SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> createWhiteboxSubscriberProbe(TestEnvironment env)

signalNext

public T signalNext()
             throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

nextT

public T nextT()
        throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

verifyNoAsyncErrors

public void verifyNoAsyncErrors()