Class SubscriberBlackboxVerification.BlackboxTestStage

java.lang.Object

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

org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStage

All Implemented Interfaces:

Publisher<T>

Enclosing class:

SubscriberBlackboxVerification<T>

public class SubscriberBlackboxVerification.BlackboxTestStage
extends TestEnvironment.ManualPublisher<T>

Field Summary

Fields

Modifier and Type	Field	Description
T	lastT
Publisher<T>	pub
private Optional<SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T>>	subProxy
TestEnvironment.ManualSubscriber<T>	tees

Fields inherited from class TestEnvironment.ManualPublisher

cancelled, env, pendingDemand, requests, subscriber

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T>	createBlackboxSubscriberProxy(TestEnvironment env, Subscriber<T> sub)
Publisher<T>	createHelperPublisher(long elements)
T	nextT()
T	signalNext()
Subscriber<? super T>	sub()
SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T>	subProxy()	Proxy for the sub() Subscriber, providing certain assertions on methods being called on the Subscriber.

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

lastT

public T lastT

subProxy

private Optional<SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T>> subProxy

Constructor Details

BlackboxTestStage

public BlackboxTestStage(TestEnvironment env)
                  throws InterruptedException

Throws:

InterruptedException

BlackboxTestStage

public BlackboxTestStage(TestEnvironment env,
 boolean runDefaultInit)
                  throws InterruptedException

Throws:

InterruptedException

Method Details

sub

public Subscriber<? super T> sub()

subProxy

public SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T> subProxy()

Proxy for the sub() Subscriber, providing certain assertions on methods being called on the Subscriber.

createHelperPublisher

public Publisher<T> createHelperPublisher(long elements)

createBlackboxSubscriberProxy

public SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T> createBlackboxSubscriberProxy(TestEnvironment env,
 Subscriber<T> sub)

signalNext

public T signalNext()
             throws InterruptedException

Throws:

InterruptedException

nextT

public T nextT()
        throws InterruptedException

Throws:

InterruptedException