Package org.reactivestreams.tck.flow

Class FlowSubscriberWhiteboxVerification<T>

java.lang.Object

org.reactivestreams.tck.WithHelperPublisher<T>

org.reactivestreams.tck.SubscriberWhiteboxVerification<T>

org.reactivestreams.tck.flow.FlowSubscriberWhiteboxVerification<T>

All Implemented Interfaces:

org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

public abstract class FlowSubscriberWhiteboxVerification<T>
extends org.reactivestreams.tck.SubscriberWhiteboxVerification<T>
implements org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

Provides whitebox style tests for verifying Flow.Subscriber and Flow.Subscription specification rules.

See Also:

Flow.Subscriber, Flow.Subscription

Nested Class Summary

Nested classes/interfaces inherited from class org.reactivestreams.tck.SubscriberWhiteboxVerification

org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe<T extends java.lang.Object>, org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T extends java.lang.Object>, org.reactivestreams.tck.SubscriberWhiteboxVerification.SubscriberProbe<T extends java.lang.Object>, org.reactivestreams.tck.SubscriberWhiteboxVerification.SubscriberPuppet, org.reactivestreams.tck.SubscriberWhiteboxVerification.SubscriberPuppeteer, org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T extends java.lang.Object>, org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	FlowSubscriberWhiteboxVerification(org.reactivestreams.tck.TestEnvironment env)

Method Summary

Modifier and Type	Method	Description
protected abstract java.util.concurrent.Flow.Subscriber<T>	createFlowSubscriber(org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> probe)	This is the main method you must implement in your test incarnation.
org.reactivestreams.Subscriber<T>	createSubscriber(org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> probe)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from class org.reactivestreams.tck.SubscriberWhiteboxVerification

notVerified, notVerified, optionalSubscriberTestWithoutSetup, publisherExecutorService, required_exerciseWhiteboxHappyPath, required_spec201_mustSignalDemandViaSubscriptionRequest, required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete, required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnError, required_spec205_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal, required_spec208_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel, required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall, required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall, required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall, required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall, required_spec213_onError_mustThrowNullPointerExceptionWhenParametersAreNull, required_spec213_onNext_mustThrowNullPointerExceptionWhenParametersAreNull, required_spec213_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull, required_spec308_requestMustRegisterGivenNumberElementsToBeProduced, setUp, shutdownPublisherExecutorService, startPublisherExecutorService, subscriberTest, subscriberTestWithoutSetup, untested_spec202_shouldAsynchronouslyDispatch, untested_spec204_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError, untested_spec206_mustCallSubscriptionCancelIfItIsNoLongerValid, untested_spec207_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization, untested_spec211_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents, untested_spec212_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality_specViolation, untested_spec213_failingOnSignalInvocation, untested_spec301_mustNotBeCalledOutsideSubscriberContext, untested_spec310_requestMaySynchronouslyCallOnNextOnSubscriber, untested_spec311_requestMaySynchronouslyCallOnCompleteOrOnError, untested_spec314_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists, untested_spec315_cancelMustNotThrowExceptionAndMustSignalOnError, untested_spec316_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber

Methods inherited from interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

required_exerciseWhiteboxHappyPath, required_spec201_mustSignalDemandViaSubscriptionRequest, required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete, required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnError, required_spec205_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal, required_spec208_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel, required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall, required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall, required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall, required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall, required_spec213_onError_mustThrowNullPointerExceptionWhenParametersAreNull, required_spec213_onNext_mustThrowNullPointerExceptionWhenParametersAreNull, required_spec213_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull, required_spec308_requestMustRegisterGivenNumberElementsToBeProduced, untested_spec202_shouldAsynchronouslyDispatch, untested_spec204_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError, untested_spec206_mustCallSubscriptionCancelIfItIsNoLongerValid, untested_spec207_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization, untested_spec211_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents, untested_spec212_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality_specViolation, untested_spec213_failingOnSignalInvocation, untested_spec301_mustNotBeCalledOutsideSubscriberContext, untested_spec310_requestMaySynchronouslyCallOnNextOnSubscriber, untested_spec311_requestMaySynchronouslyCallOnCompleteOrOnError, untested_spec314_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists, untested_spec315_cancelMustNotThrowExceptionAndMustSignalOnError, untested_spec316_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber

Methods inherited from class org.reactivestreams.tck.WithHelperPublisher

createElement, createHelperPublisher

Constructor Detail

FlowSubscriberWhiteboxVerification

protected FlowSubscriberWhiteboxVerification(org.reactivestreams.tck.TestEnvironment env)

Method Detail

createSubscriber

public final org.reactivestreams.Subscriber<T> createSubscriber(org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> probe)

Specified by:

createSubscriber in class org.reactivestreams.tck.SubscriberWhiteboxVerification<T>

createFlowSubscriber

protected abstract java.util.concurrent.Flow.Subscriber<T> createFlowSubscriber(org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> probe)

This is the main method you must implement in your test incarnation. It must create a new Subscriber instance to be subjected to the testing logic. In order to be meaningfully testable your Subscriber must inform the given `WhiteboxSubscriberProbe` of the respective events having been received.