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 toTestEnvironment.ManualSubscriberWithSubscriptionSupport
but does not accumulate values signalled viaonNext
, 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)
-