001package org.reactivestreams.tck.support; 002 003/** 004 * Internal TCK use only. 005 * Add / Remove tests for PublisherVerificaSubscriberWhiteboxVerification here to make sure that they arre added/removed in the other places. 006 */ 007public interface SubscriberWhiteboxVerificationRules { 008 void required_exerciseWhiteboxHappyPath() throws Throwable; 009 void required_spec201_mustSignalDemandViaSubscriptionRequest() throws Throwable; 010 void untested_spec202_shouldAsynchronouslyDispatch() throws Exception; 011 void required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete() throws Throwable; 012 void required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnError() throws Throwable; 013 void untested_spec204_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError() throws Exception; 014 void required_spec205_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal() throws Throwable; 015 void untested_spec206_mustCallSubscriptionCancelIfItIsNoLongerValid() throws Exception; 016 void untested_spec207_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization() throws Exception; 017 void required_spec208_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel() throws Throwable; 018 void required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall() throws Throwable; 019 void required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall() throws Throwable; 020 void required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall() throws Throwable; 021 void required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall() throws Throwable; 022 void untested_spec211_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents() throws Exception; 023 void untested_spec212_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality_specViolation() throws Throwable; 024 void untested_spec213_failingOnSignalInvocation() throws Exception; 025 void required_spec213_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull() throws Throwable; 026 void required_spec213_onNext_mustThrowNullPointerExceptionWhenParametersAreNull() throws Throwable; 027 void required_spec213_onError_mustThrowNullPointerExceptionWhenParametersAreNull() throws Throwable; 028 void untested_spec301_mustNotBeCalledOutsideSubscriberContext() throws Exception; 029 void required_spec308_requestMustRegisterGivenNumberElementsToBeProduced() throws Throwable; 030 void untested_spec310_requestMaySynchronouslyCallOnNextOnSubscriber() throws Exception; 031 void untested_spec311_requestMaySynchronouslyCallOnCompleteOrOnError() throws Exception; 032 void untested_spec314_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists() throws Exception; 033 void untested_spec315_cancelMustNotThrowExceptionAndMustSignalOnError() throws Exception; 034 void untested_spec316_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber() throws Exception; 035}