Package org.reactivestreams.tck

Class SubscriberBlackboxVerification.BlackboxTestStage

java.lang.Object

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

org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStage

All Implemented Interfaces:

org.reactivestreams.Publisher<T>

Enclosing class:

SubscriberBlackboxVerification<T>

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

Field Summary

Fields

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

Method Summary

Modifier and Type	Method	Description
SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T>	createBlackboxSubscriberProxy(TestEnvironment env, org.reactivestreams.Subscriber<T> sub)
org.reactivestreams.Publisher<T>	createHelperPublisher(long elements)
T	nextT()
T	signalNext()
org.reactivestreams.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 org.reactivestreams.tck.TestEnvironment.ManualPublisher

expectCancelling, expectCancelling, expectExactRequest, expectExactRequest, expectNoRequest, expectNoRequest, expectRequest, expectRequest, expectRequest, isCancelled, 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

lastT

public T lastT

Constructor Detail

BlackboxTestStage

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

Throws:

java.lang.InterruptedException

BlackboxTestStage

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

Throws:

java.lang.InterruptedException

Method Detail

sub

public org.reactivestreams.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 org.reactivestreams.Publisher<T> createHelperPublisher(long elements)

createBlackboxSubscriberProxy

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

signalNext

public T signalNext()
             throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

nextT

public T nextT()
        throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException