Class SubscriberWhiteboxVerification.WhiteboxTestStage

java.lang.Object

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

org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

All Implemented Interfaces:

Publisher<T>

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
Publisher<T>	pub
TestEnvironment.ManualSubscriber<T>	tees

Fields inherited from class 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
Publisher<T>	createHelperPublisher(long elements)
SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T>	createWhiteboxSubscriberProbe(TestEnvironment env)
T	nextT()
SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T>	probe()
SubscriberWhiteboxVerification.SubscriberPuppet	puppet()
T	signalNext()
private T	signalNext(T element)
Subscriber<? super T>	sub()
void	verifyNoAsyncErrors()

Methods inherited from class TestEnvironment.ManualPublisher

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

Methods inherited from class Object

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

Field Details

pub

public Publisher<T> pub

tees

public TestEnvironment.ManualSubscriber<T> tees

probe

public SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> probe

lastT

public T lastT

Constructor Details

WhiteboxTestStage

public WhiteboxTestStage(TestEnvironment env)
                  throws InterruptedException

Throws:

InterruptedException

WhiteboxTestStage

public WhiteboxTestStage(TestEnvironment env,
 boolean runDefaultInit)
                  throws InterruptedException

Throws:

InterruptedException

Method Details

sub

public Subscriber<? super T> sub()

puppet

public SubscriberWhiteboxVerification.SubscriberPuppet puppet()

probe

public SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> probe()

createHelperPublisher

public Publisher<T> createHelperPublisher(long elements)

createWhiteboxSubscriberProbe

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

signalNext

public T signalNext()
             throws InterruptedException

Throws:

InterruptedException

signalNext

private T signalNext(T element)
              throws InterruptedException

Throws:

InterruptedException

nextT

public T nextT()
        throws InterruptedException

Throws:

InterruptedException

verifyNoAsyncErrors

public void verifyNoAsyncErrors()