Package org.reactivestreams.tck

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 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, 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 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 Publisher<T> pub

tees

public TestEnvironment.ManualSubscriber<T> tees

lastT

public T lastT

subProxy

private Optional<SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T>> subProxy

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 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 java.lang.InterruptedException

Throws:

java.lang.InterruptedException

nextT

public T nextT()
        throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException