Uses of Class
org.reactivestreams.tck.TestEnvironment.ManualSubscriber

Packages that use TestEnvironment.ManualSubscriber

Package	Description
org.reactivestreams.tck

Uses of TestEnvironment.ManualSubscriber in org.reactivestreams.tck

Subclasses of TestEnvironment.ManualSubscriber in org.reactivestreams.tck

Modifier and Type	Class	Description
class	IdentityProcessorVerification.ManualSubscriberWithErrorCollection<A>
static class	TestEnvironment.BlackholeSubscriberWithSubscriptionSupport<T>	Similar to TestEnvironment.ManualSubscriberWithSubscriptionSupport but does not accumulate values signalled via onNext, thus it can not be used to assert values signalled to this subscriber.
static class	TestEnvironment.ManualSubscriberWithSubscriptionSupport<T>

Fields in org.reactivestreams.tck declared as TestEnvironment.ManualSubscriber

Modifier and Type	Field	Description
private TestEnvironment.ManualSubscriber<T>	IdentityProcessorVerification.TestSetup.tees
TestEnvironment.ManualSubscriber<T>	SubscriberBlackboxVerification.BlackboxTestStage.tees
TestEnvironment.ManualSubscriber<T>	SubscriberWhiteboxVerification.WhiteboxTestStage.tees

Methods in org.reactivestreams.tck that return TestEnvironment.ManualSubscriber

Modifier and Type	Method	Description
<T> TestEnvironment.ManualSubscriber<T>	TestEnvironment.newBlackholeSubscriber(Publisher<T> pub)
<T> TestEnvironment.ManualSubscriber<T>	TestEnvironment.newManualSubscriber(Publisher<T> pub)
<T> TestEnvironment.ManualSubscriber<T>	TestEnvironment.newManualSubscriber(Publisher<T> pub, long timeoutMillis)
TestEnvironment.ManualSubscriber<T>	IdentityProcessorVerification.TestSetup.newSubscriber()

Methods in org.reactivestreams.tck with parameters of type TestEnvironment.ManualSubscriber

Modifier and Type	Method	Description
void	IdentityProcessorVerification.TestSetup.expectNextElement(TestEnvironment.ManualSubscriber<T> sub, T expected)
void	IdentityProcessorVerification.TestSetup.expectNextElement(TestEnvironment.ManualSubscriber<T> sub, T expected, java.lang.String errorMessageAddendum)