SubscriberBlackboxVerification (reactive-streams-tck 1.0.0 API)

java.lang.Object
- org.reactivestreams.tck.WithHelperPublisher<T>
- - org.reactivestreams.tck.SubscriberBlackboxVerification<T>

All Implemented Interfaces:

SubscriberBlackboxVerificationRules
```
public abstract class SubscriberBlackboxVerification<T>
extends WithHelperPublisher<T>
implements SubscriberBlackboxVerificationRules
```
Provides tests for verifying Subscriber and Subscription specification rules, without any modifications to the tested implementation (also known as "Black Box" testing). This verification is NOT able to check many of the rules of the spec, and if you want more verification of your implementation you'll have to implement org.reactivestreams.tck.SubscriberWhiteboxVerification instead.

See Also:

Subscriber, Subscription

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

class SubscriberBlackboxVerification.BlackboxTestStage

Nested Classes
Modifier and Type	Class and Description
`class`	`SubscriberBlackboxVerification.BlackboxTestStage`

Field Summary

Fields
Modifier and Type Field and Description

protected TestEnvironment env

Fields
Modifier and Type	Field and Description
`protected TestEnvironment`	`env`

Constructor Summary

Constructors
Modifier Constructor and Description

protected SubscriberBlackboxVerification(TestEnvironment env)

Constructors
Modifier	Constructor and Description
`protected`	`SubscriberBlackboxVerification(TestEnvironment env)`

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`blackboxSubscriberTest(org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStageTestRun body)`
`void`	`blackboxSubscriberWithoutSetupTest(org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStageTestRun body)`
`abstract org.reactivestreams.Subscriber<T>`	`createSubscriber()` This is the main method you must implement in your test incarnation.
`void`	`notVerified()`
`java.util.concurrent.ExecutorService`	`publisherExecutorService()` ExecutorService to be used by the provided helper `Publisher`
`void`	`required_spec201_blackbox_mustSignalDemandViaSubscriptionRequest()`
`void`	`required_spec203_blackbox_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete()`
`void`	`required_spec203_blackbox_mustNotCallMethodsOnSubscriptionOrPublisherInOnError()`
`void`	`required_spec205_blackbox_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal()`
`void`	`required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall()`
`void`	`required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall()`
`void`	`required_spec210_blackbox_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall()`
`void`	`required_spec213_blackbox_onError_mustThrowNullPointerExceptionWhenParametersAreNull()`
`void`	`required_spec213_blackbox_onNext_mustThrowNullPointerExceptionWhenParametersAreNull()`
`void`	`required_spec213_blackbox_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull()`
`void`	`setUp()`
`void`	`shutdownPublisherExecutorService()`
`void`	`startPublisherExecutorService()`
`void`	`triggerRequest(org.reactivestreams.Subscriber<? super T> subscriber)` Override this method if the Subscriber implementation you are verifying needs an external signal before it signals demand to its Publisher.
`void`	`untested_spec202_blackbox_shouldAsynchronouslyDispatch()`
`void`	`untested_spec204_blackbox_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError()`
`void`	`untested_spec206_blackbox_mustCallSubscriptionCancelIfItIsNoLongerValid()`
`void`	`untested_spec207_blackbox_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization()`
`void`	`untested_spec208_blackbox_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel()`
`void`	`untested_spec211_blackbox_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents()`
`void`	`untested_spec212_blackbox_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality()`
`void`	`untested_spec213_blackbox_failingOnSignalInvocation()`
`void`	`untested_spec301_blackbox_mustNotBeCalledOutsideSubscriberContext()`
`void`	`untested_spec308_blackbox_requestMustRegisterGivenNumberElementsToBeProduced()`
`void`	`untested_spec310_blackbox_requestMaySynchronouslyCallOnNextOnSubscriber()`
`void`	`untested_spec311_blackbox_requestMaySynchronouslyCallOnCompleteOrOnError()`
`void`	`untested_spec314_blackbox_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists()`
`void`	`untested_spec315_blackbox_cancelMustNotThrowExceptionAndMustSignalOnError()`
`void`	`untested_spec316_blackbox_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber()`

Methods inherited from class org.reactivestreams.tck.WithHelperPublisher
createElement, createHelperPublisher

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - env
```
protected final TestEnvironment env
```
- Constructor Detail
  - SubscriberBlackboxVerification
```
protected SubscriberBlackboxVerification(TestEnvironment env)
```
- Method Detail
  - createSubscriber
```
public abstract org.reactivestreams.Subscriber<T> createSubscriber()
```
    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.
  - triggerRequest
```
public void triggerRequest(org.reactivestreams.Subscriber<? super T> subscriber)
```
    Override this method if the Subscriber implementation you are verifying needs an external signal before it signals demand to its Publisher. By default this method does nothing.
  - startPublisherExecutorService
```
public void startPublisherExecutorService()
```
  - shutdownPublisherExecutorService
```
public void shutdownPublisherExecutorService()
```
  - publisherExecutorService
```
public java.util.concurrent.ExecutorService publisherExecutorService()
```
    Description copied from class: WithHelperPublisher
    
    ExecutorService to be used by the provided helper Publisher
    
    Specified by:
    
    publisherExecutorService in class WithHelperPublisher<T>
  - setUp
```
public void setUp()
           throws java.lang.Exception
```
    Throws:
    
    java.lang.Exception
  - required_spec201_blackbox_mustSignalDemandViaSubscriptionRequest
```
public void required_spec201_blackbox_mustSignalDemandViaSubscriptionRequest()
                                                                      throws java.lang.Throwable
```
    Specified by:
    
    required_spec201_blackbox_mustSignalDemandViaSubscriptionRequest in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec202_blackbox_shouldAsynchronouslyDispatch
```
public void untested_spec202_blackbox_shouldAsynchronouslyDispatch()
                                                            throws java.lang.Exception
```
    Specified by:
    
    untested_spec202_blackbox_shouldAsynchronouslyDispatch in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - required_spec203_blackbox_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete
```
public void required_spec203_blackbox_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete()
                                                                                       throws java.lang.Throwable
```
    Specified by:
    
    required_spec203_blackbox_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec203_blackbox_mustNotCallMethodsOnSubscriptionOrPublisherInOnError
```
public void required_spec203_blackbox_mustNotCallMethodsOnSubscriptionOrPublisherInOnError()
                                                                                    throws java.lang.Throwable
```
    Specified by:
    
    required_spec203_blackbox_mustNotCallMethodsOnSubscriptionOrPublisherInOnError in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec204_blackbox_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError
```
public void untested_spec204_blackbox_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError()
                                                                                                         throws java.lang.Exception
```
    Specified by:
    
    untested_spec204_blackbox_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - required_spec205_blackbox_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal
```
public void required_spec205_blackbox_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal()
                                                                                                                         throws java.lang.Exception
```
    Specified by:
    
    required_spec205_blackbox_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - untested_spec206_blackbox_mustCallSubscriptionCancelIfItIsNoLongerValid
```
public void untested_spec206_blackbox_mustCallSubscriptionCancelIfItIsNoLongerValid()
                                                                             throws java.lang.Exception
```
    Specified by:
    
    untested_spec206_blackbox_mustCallSubscriptionCancelIfItIsNoLongerValid in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - untested_spec207_blackbox_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization
```
public void untested_spec207_blackbox_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization()
                                                                                                                        throws java.lang.Exception
```
    Specified by:
    
    untested_spec207_blackbox_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - untested_spec208_blackbox_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel
```
public void untested_spec208_blackbox_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel()
                                                                                                       throws java.lang.Throwable
```
    Specified by:
    
    untested_spec208_blackbox_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall
```
public void required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall()
                                                                                                 throws java.lang.Throwable
```
    Specified by:
    
    required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall
```
public void required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall()
                                                                                                    throws java.lang.Throwable
```
    Specified by:
    
    required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec210_blackbox_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall
```
public void required_spec210_blackbox_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall()
                                                                                              throws java.lang.Throwable
```
    Specified by:
    
    required_spec210_blackbox_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec211_blackbox_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents
```
public void untested_spec211_blackbox_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents()
                                                                                                                  throws java.lang.Exception
```
    Specified by:
    
    untested_spec211_blackbox_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - untested_spec212_blackbox_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality
```
public void untested_spec212_blackbox_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality()
                                                                                       throws java.lang.Throwable
```
    Specified by:
    
    untested_spec212_blackbox_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec213_blackbox_failingOnSignalInvocation
```
public void untested_spec213_blackbox_failingOnSignalInvocation()
                                                         throws java.lang.Exception
```
    Specified by:
    
    untested_spec213_blackbox_failingOnSignalInvocation in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - required_spec213_blackbox_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull
```
public void required_spec213_blackbox_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull()
                                                                                              throws java.lang.Throwable
```
    Specified by:
    
    required_spec213_blackbox_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec213_blackbox_onNext_mustThrowNullPointerExceptionWhenParametersAreNull
```
public void required_spec213_blackbox_onNext_mustThrowNullPointerExceptionWhenParametersAreNull()
                                                                                         throws java.lang.Throwable
```
    Specified by:
    
    required_spec213_blackbox_onNext_mustThrowNullPointerExceptionWhenParametersAreNull in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec213_blackbox_onError_mustThrowNullPointerExceptionWhenParametersAreNull
```
public void required_spec213_blackbox_onError_mustThrowNullPointerExceptionWhenParametersAreNull()
                                                                                          throws java.lang.Throwable
```
    Specified by:
    
    required_spec213_blackbox_onError_mustThrowNullPointerExceptionWhenParametersAreNull in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec301_blackbox_mustNotBeCalledOutsideSubscriberContext
```
public void untested_spec301_blackbox_mustNotBeCalledOutsideSubscriberContext()
                                                                       throws java.lang.Exception
```
    Specified by:
    
    untested_spec301_blackbox_mustNotBeCalledOutsideSubscriberContext in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - untested_spec308_blackbox_requestMustRegisterGivenNumberElementsToBeProduced
```
public void untested_spec308_blackbox_requestMustRegisterGivenNumberElementsToBeProduced()
                                                                                  throws java.lang.Throwable
```
    Specified by:
    
    untested_spec308_blackbox_requestMustRegisterGivenNumberElementsToBeProduced in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec310_blackbox_requestMaySynchronouslyCallOnNextOnSubscriber
```
public void untested_spec310_blackbox_requestMaySynchronouslyCallOnNextOnSubscriber()
                                                                             throws java.lang.Exception
```
    Specified by:
    
    untested_spec310_blackbox_requestMaySynchronouslyCallOnNextOnSubscriber in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - untested_spec311_blackbox_requestMaySynchronouslyCallOnCompleteOrOnError
```
public void untested_spec311_blackbox_requestMaySynchronouslyCallOnCompleteOrOnError()
                                                                              throws java.lang.Exception
```
    Specified by:
    
    untested_spec311_blackbox_requestMaySynchronouslyCallOnCompleteOrOnError in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - untested_spec314_blackbox_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists
```
public void untested_spec314_blackbox_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists()
                                                                                               throws java.lang.Exception
```
    Specified by:
    
    untested_spec314_blackbox_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - untested_spec315_blackbox_cancelMustNotThrowExceptionAndMustSignalOnError
```
public void untested_spec315_blackbox_cancelMustNotThrowExceptionAndMustSignalOnError()
                                                                               throws java.lang.Exception
```
    Specified by:
    
    untested_spec315_blackbox_cancelMustNotThrowExceptionAndMustSignalOnError in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - untested_spec316_blackbox_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber
```
public void untested_spec316_blackbox_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber()
                                                                                       throws java.lang.Exception
```
    Specified by:
    
    untested_spec316_blackbox_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber in interface SubscriberBlackboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - blackboxSubscriberTest
```
public void blackboxSubscriberTest(org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStageTestRun body)
                            throws java.lang.Throwable
```
    Throws:
    
    java.lang.Throwable
  - blackboxSubscriberWithoutSetupTest
```
public void blackboxSubscriberWithoutSetupTest(org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStageTestRun body)
                                        throws java.lang.Throwable
```
    Throws:
    
    java.lang.Throwable
  - notVerified
```
public void notVerified()
```

Class SubscriberBlackboxVerification<T>

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class org.reactivestreams.tck.WithHelperPublisher

Methods inherited from class java.lang.Object

Field Detail

env

Constructor Detail

SubscriberBlackboxVerification

Method Detail

createSubscriber

triggerRequest

startPublisherExecutorService

shutdownPublisherExecutorService

publisherExecutorService

setUp

required_spec201_blackbox_mustSignalDemandViaSubscriptionRequest

untested_spec202_blackbox_shouldAsynchronouslyDispatch

required_spec203_blackbox_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete

required_spec203_blackbox_mustNotCallMethodsOnSubscriptionOrPublisherInOnError

untested_spec204_blackbox_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError

required_spec205_blackbox_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal

untested_spec206_blackbox_mustCallSubscriptionCancelIfItIsNoLongerValid

untested_spec207_blackbox_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization

untested_spec208_blackbox_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel

required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall

required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall

required_spec210_blackbox_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall

untested_spec211_blackbox_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents

untested_spec212_blackbox_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality

untested_spec213_blackbox_failingOnSignalInvocation

required_spec213_blackbox_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull

required_spec213_blackbox_onNext_mustThrowNullPointerExceptionWhenParametersAreNull

required_spec213_blackbox_onError_mustThrowNullPointerExceptionWhenParametersAreNull

untested_spec301_blackbox_mustNotBeCalledOutsideSubscriberContext

untested_spec308_blackbox_requestMustRegisterGivenNumberElementsToBeProduced

untested_spec310_blackbox_requestMaySynchronouslyCallOnNextOnSubscriber

untested_spec311_blackbox_requestMaySynchronouslyCallOnCompleteOrOnError

untested_spec314_blackbox_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists

untested_spec315_blackbox_cancelMustNotThrowExceptionAndMustSignalOnError

untested_spec316_blackbox_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber

blackboxSubscriberTest

blackboxSubscriberWithoutSetupTest

notVerified