org.reactivestreams.tck

Class SubscriberWhiteboxVerification.WhiteboxTestStage

java.lang.Object

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

org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

All Implemented Interfaces:

org.reactivestreams.Publisher<T>

Enclosing class:

SubscriberWhiteboxVerification<T>

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

Field Summary

Fields

Modifier and Type	Field and 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 and Description
WhiteboxTestStage(TestEnvironment env)
WhiteboxTestStage(TestEnvironment env, boolean runDefaultInit)

Method Summary

Modifier and Type	Method and 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 org.reactivestreams.tck.TestEnvironment.ManualPublisher

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

Methods inherited from class java.lang.Object

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

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()