Package org.reactivestreams.tck.flow.support

Interface SubscriberWhiteboxVerificationRules

All Known Implementing Classes:

IdentityProcessorVerification, SubscriberWhiteboxVerification

public interface SubscriberWhiteboxVerificationRules

Internal TCK use only. Add / Remove tests for PublisherVerificaSubscriberWhiteboxVerification here to make sure that they arre added/removed in the other places.

Method Summary

Modifier and Type	Method	Description
void	required_exerciseWhiteboxHappyPath()
void	required_spec201_mustSignalDemandViaSubscriptionRequest()
void	required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete()
void	required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnError()
void	required_spec205_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal()
void	required_spec208_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel()
void	required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall()
void	required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall()
void	required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall()
void	required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall()
void	required_spec213_onError_mustThrowNullPointerExceptionWhenParametersAreNull()
void	required_spec213_onNext_mustThrowNullPointerExceptionWhenParametersAreNull()
void	required_spec213_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull()
void	required_spec308_requestMustRegisterGivenNumberElementsToBeProduced()
void	untested_spec202_shouldAsynchronouslyDispatch()
void	untested_spec204_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError()
void	untested_spec206_mustCallSubscriptionCancelIfItIsNoLongerValid()
void	untested_spec207_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization()
void	untested_spec211_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents()
void	untested_spec212_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality_specViolation()
void	untested_spec213_failingOnSignalInvocation()
void	untested_spec301_mustNotBeCalledOutsideSubscriberContext()
void	untested_spec310_requestMaySynchronouslyCallOnNextOnSubscriber()
void	untested_spec311_requestMaySynchronouslyCallOnCompleteOrOnError()
void	untested_spec314_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists()
void	untested_spec315_cancelMustNotThrowExceptionAndMustSignalOnError()
void	untested_spec316_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber()

Method Detail

required_exerciseWhiteboxHappyPath

void required_exerciseWhiteboxHappyPath()
                                 throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec201_mustSignalDemandViaSubscriptionRequest

void required_spec201_mustSignalDemandViaSubscriptionRequest()
                                                      throws java.lang.Throwable

Throws:

java.lang.Throwable

untested_spec202_shouldAsynchronouslyDispatch

void untested_spec202_shouldAsynchronouslyDispatch()
                                            throws java.lang.Exception

Throws:

java.lang.Exception

required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete

void required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete()
                                                                       throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnError

void required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnError()
                                                                    throws java.lang.Throwable

Throws:

java.lang.Throwable

untested_spec204_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError

void untested_spec204_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError()
                                                                                         throws java.lang.Exception

Throws:

java.lang.Exception

required_spec205_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal

void required_spec205_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal()
                                                                                                         throws java.lang.Throwable

Throws:

java.lang.Throwable

untested_spec206_mustCallSubscriptionCancelIfItIsNoLongerValid

void untested_spec206_mustCallSubscriptionCancelIfItIsNoLongerValid()
                                                             throws java.lang.Exception

Throws:

java.lang.Exception

untested_spec207_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization

void untested_spec207_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization()
                                                                                                        throws java.lang.Exception

Throws:

java.lang.Exception

required_spec208_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel

void required_spec208_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel()
                                                                                       throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall

void required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall()
                                                                                 throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall

void required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall()
                                                                                    throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall

void required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall()
                                                                              throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall

void required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall()
                                                                                 throws java.lang.Throwable

Throws:

java.lang.Throwable

untested_spec211_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents

void untested_spec211_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents()
                                                                                                  throws java.lang.Exception

Throws:

java.lang.Exception

untested_spec212_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality_specViolation

void untested_spec212_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality_specViolation()
                                                                                     throws java.lang.Throwable

Throws:

java.lang.Throwable

untested_spec213_failingOnSignalInvocation

void untested_spec213_failingOnSignalInvocation()
                                         throws java.lang.Exception

Throws:

java.lang.Exception

required_spec213_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull

void required_spec213_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull()
                                                                              throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec213_onNext_mustThrowNullPointerExceptionWhenParametersAreNull

void required_spec213_onNext_mustThrowNullPointerExceptionWhenParametersAreNull()
                                                                         throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec213_onError_mustThrowNullPointerExceptionWhenParametersAreNull

void required_spec213_onError_mustThrowNullPointerExceptionWhenParametersAreNull()
                                                                          throws java.lang.Throwable

Throws:

java.lang.Throwable

untested_spec301_mustNotBeCalledOutsideSubscriberContext

void untested_spec301_mustNotBeCalledOutsideSubscriberContext()
                                                       throws java.lang.Exception

Throws:

java.lang.Exception

required_spec308_requestMustRegisterGivenNumberElementsToBeProduced

void required_spec308_requestMustRegisterGivenNumberElementsToBeProduced()
                                                                  throws java.lang.Throwable

Throws:

java.lang.Throwable

untested_spec310_requestMaySynchronouslyCallOnNextOnSubscriber

void untested_spec310_requestMaySynchronouslyCallOnNextOnSubscriber()
                                                             throws java.lang.Exception

Throws:

java.lang.Exception

untested_spec311_requestMaySynchronouslyCallOnCompleteOrOnError

void untested_spec311_requestMaySynchronouslyCallOnCompleteOrOnError()
                                                              throws java.lang.Exception

Throws:

java.lang.Exception

untested_spec314_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists

void untested_spec314_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists()
                                                                               throws java.lang.Exception

Throws:

java.lang.Exception

untested_spec315_cancelMustNotThrowExceptionAndMustSignalOnError

void untested_spec315_cancelMustNotThrowExceptionAndMustSignalOnError()
                                                               throws java.lang.Exception

Throws:

java.lang.Exception

untested_spec316_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber

void untested_spec316_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber()
                                                                       throws java.lang.Exception

Throws:

java.lang.Exception