IdentityProcessorVerification (reactive-streams-tck 1.0.0 API)

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

All Implemented Interfaces:: PublisherVerificationRules, SubscriberWhiteboxVerificationRules

public abstract class IdentityProcessorVerification<T>
extends WithHelperPublisher<T>
implements SubscriberWhiteboxVerificationRules, PublisherVerificationRules

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

class IdentityProcessorVerification.ManualSubscriberWithErrorCollection<A>

class IdentityProcessorVerification.TestSetup

Nested Classes
Modifier and Type	Class and Description
`class`	`IdentityProcessorVerification.ManualSubscriberWithErrorCollection<A>`
`class`	`IdentityProcessorVerification.TestSetup`

Constructor Summary

Constructors
Constructor and Description
`IdentityProcessorVerification(TestEnvironment env)` Test class must specify the expected time it takes for the publisher to shut itself down when the the last downstream `Subscription` is cancelled.
`IdentityProcessorVerification(TestEnvironment env, long publisherReferenceGCTimeoutMillis)` Test class must specify the expected time it takes for the publisher to shut itself down when the the last downstream `Subscription` is cancelled.
`IdentityProcessorVerification(TestEnvironment env, long publisherReferenceGCTimeoutMillis, int processorBufferSize)` Test class must specify the expected time it takes for the publisher to shut itself down when the the last downstream `Subscription` is cancelled.

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and Description
`long`	`boundedDepthOfOnNextAndRequestRecursion()` In order to verify rule 3.3 of the reactive streams spec, this number will be used to check if a `Subscription` actually solves the "unbounded recursion" problem by not allowing the number of recursive calls to exceed the number returned by this method.
`abstract org.reactivestreams.Publisher<T>`	`createFailedPublisher()` By implementing this method, additional TCK tests concerning a "failed" publishers will be run.
`abstract org.reactivestreams.Processor<T,T>`	`createIdentityProcessor(int bufferSize)` This is the main method you must implement in your test incarnation.
`org.reactivestreams.Publisher<T>`	`createPublisher(long elements)`
`org.reactivestreams.Subscriber<T>`	`createSubscriber(SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> probe)`
`long`	`maxElementsFromPublisher()` Override and return lower value if your Publisher is only able to produce a known number of elements.
`long`	`maxSupportedSubscribers()` Describes the tested implementation in terms of how many subscribers they can support.
`void`	`mustImmediatelyPassOnOnErrorEventsReceivedFromItsUpstreamToItsDownstream()`
`void`	`notVerified()`
`void`	`notVerified(java.lang.String message)`
`void`	`optional_spec104_mustSignalOnErrorWhenFails()`
`void`	`optional_spec105_emptyStreamMustTerminateBySignallingOnComplete()`
`void`	`optional_spec111_maySupportMultiSubscribe()`
`void`	`optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfront()`
`void`	`optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfrontAndCompleteAsExpected()`
`void`	`optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingOneByOne()`
`void`	`optionalMultipleSubscribersTest(long requiredSubscribersSupport, Function<java.lang.Long,IdentityProcessorVerification.TestSetup> body)` Test for feature that REQUIRES multiple subscribers to be supported by Publisher.
`void`	`required_createPublisher1MustProduceAStreamOfExactly1Element()`
`void`	`required_createPublisher3MustProduceAStreamOfExactly3Elements()`
`void`	`required_exerciseWhiteboxHappyPath()`
`void`	`required_mustRequestFromUpstreamForElementsThatHaveBeenRequestedLongAgo()`
`void`	`required_spec101_subscriptionRequestMustResultInTheCorrectNumberOfProducedElements()`
`void`	`required_spec102_maySignalLessThanRequestedAndTerminateSubscription()`
`void`	`required_spec104_mustCallOnErrorOnAllItsSubscribersIfItEncountersANonRecoverableError()`
`void`	`required_spec105_mustSignalOnCompleteWhenFiniteStreamTerminates()`
`void`	`required_spec107_mustNotEmitFurtherSignalsOnceOnCompleteHasBeenSignalled()`
`void`	`required_spec109_mayRejectCallsToSubscribeIfPublisherIsUnableOrUnwillingToServeThemRejectionMustTriggerOnErrorAfterOnSubscribe()`
`void`	`required_spec109_mustIssueOnSubscribeForNonNullSubscriber()`
`void`	`required_spec109_subscribeThrowNPEOnNullSubscriber()`
`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_spec302_mustAllowSynchronousRequestCallsFromOnNextAndOnSubscribe()`
`void`	`required_spec303_mustNotAllowUnboundedRecursion()`
`void`	`required_spec306_afterSubscriptionIsCancelledRequestMustBeNops()`
`void`	`required_spec307_afterSubscriptionIsCancelledAdditionalCancelationsMustBeNops()`
`void`	`required_spec308_requestMustRegisterGivenNumberElementsToBeProduced()`
`void`	`required_spec309_requestNegativeNumberMustSignalIllegalArgumentException()`
`void`	`required_spec309_requestZeroMustSignalIllegalArgumentException()`
`void`	`required_spec312_cancelMustMakeThePublisherToEventuallyStopSignaling()`
`void`	`required_spec313_cancelMustMakeThePublisherEventuallyDropAllReferencesToTheSubscriber()`
`void`	`required_spec317_mustNotSignalOnErrorWhenPendingAboveLongMaxValue()`
`void`	`required_spec317_mustSupportACumulativePendingElementCountUpToLongMaxValue()`
`void`	`required_spec317_mustSupportAPendingElementCountUpToLongMaxValue()`
`void`	`required_validate_boundedDepthOfOnNextAndRequestRecursion()`
`void`	`required_validate_maxElementsFromPublisher()`
`void`	`setUp()`
`boolean`	`skipStochasticTests()` Override and return `true` in order to skip executing tests marked as `Stochastic`.
`void`	`stochastic_spec103_mustSignalOnMethodsSequentially()`
`void`	`untested_spec106_mustConsiderSubscriptionCancelledAfterOnErrorOrOnCompleteHasBeenCalled()`
`void`	`untested_spec107_mustNotEmitFurtherSignalsOnceOnErrorHasBeenSignalled()`
`void`	`untested_spec108_possiblyCanceledSubscriptionShouldNotReceiveOnErrorOrOnCompleteSignals()`
`void`	`untested_spec109_subscribeShouldNotThrowNonFatalThrowable()`
`void`	`untested_spec110_rejectASubscriptionRequestIfTheSameSubscriberSubscribesTwice()`
`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_spec304_requestShouldNotPerformHeavyComputations()`
`void`	`untested_spec305_cancelMustNotSynchronouslyPerformHeavyCompuatation()`
`void`	`untested_spec310_requestMaySynchronouslyCallOnNextOnSubscriber()`
`void`	`untested_spec311_requestMaySynchronouslyCallOnCompleteOrOnError()`
`void`	`untested_spec314_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists()`
`void`	`untested_spec315_cancelMustNotThrowExceptionAndMustSignalOnError()`
`void`	`untested_spec316_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber()`

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

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

- Constructor Detail
  - IdentityProcessorVerification
```
public IdentityProcessorVerification(TestEnvironment env)
```
    Test class must specify the expected time it takes for the publisher to shut itself down when the the last downstream Subscription is cancelled. The processor will be required to be able to buffer TestEnvironment.TEST_BUFFER_SIZE elements.
  - IdentityProcessorVerification
```
public IdentityProcessorVerification(TestEnvironment env,
                                     long publisherReferenceGCTimeoutMillis)
```
    Test class must specify the expected time it takes for the publisher to shut itself down when the the last downstream Subscription is cancelled. The processor will be required to be able to buffer TestEnvironment.TEST_BUFFER_SIZE elements.
    
    Parameters:
    
    publisherReferenceGCTimeoutMillis - used to determine after how much time a reference to a Subscriber should be already dropped by the Publisher.
  - IdentityProcessorVerification
```
public IdentityProcessorVerification(TestEnvironment env,
                                     long publisherReferenceGCTimeoutMillis,
                                     int processorBufferSize)
```
    Test class must specify the expected time it takes for the publisher to shut itself down when the the last downstream Subscription is cancelled.
    
    Parameters:
    
    publisherReferenceGCTimeoutMillis - used to determine after how much time a reference to a Subscriber should be already dropped by the Publisher.
    
    processorBufferSize - number of elements the processor is required to be able to buffer.
- Method Detail
  - createIdentityProcessor
```
public abstract org.reactivestreams.Processor<T,T> createIdentityProcessor(int bufferSize)
```
    This is the main method you must implement in your test incarnation. It must create a Publisher, which simply forwards all stream elements from its upstream to its downstream. It must be able to internally buffer the given number of elements.
    
    Parameters:
    
    bufferSize - number of elements the processor is required to be able to buffer.
  - createFailedPublisher
```
public abstract org.reactivestreams.Publisher<T> createFailedPublisher()
```
    By implementing this method, additional TCK tests concerning a "failed" publishers will be run. The expected behaviour of the Publisher returned by this method is hand out a subscription, followed by signalling onError on it, as specified by Rule 1.9. If you ignore these additional tests, return null from this method.
  - maxElementsFromPublisher
```
public long maxElementsFromPublisher()
```
    Override and return lower value if your Publisher is only able to produce a known number of elements. For example, if it is designed to return at-most-one element, return 1 from this method. Defaults to Long.MAX_VALUE - 1, meaning that the Publisher can be produce a huge but NOT an unbounded number of elements. To mark your Publisher will *never* signal an onComplete override this method and return Long.MAX_VALUE, which will result in *skipping all tests which require an onComplete to be triggered* (!).
  - boundedDepthOfOnNextAndRequestRecursion
```
public long boundedDepthOfOnNextAndRequestRecursion()
```
    In order to verify rule 3.3 of the reactive streams spec, this number will be used to check if a Subscription actually solves the "unbounded recursion" problem by not allowing the number of recursive calls to exceed the number returned by this method.
    
    See Also:
    
    reactive streams spec, rule 3.3, PublisherVerification.required_spec303_mustNotAllowUnboundedRecursion()
  - skipStochasticTests
```
public boolean skipStochasticTests()
```
    Override and return true in order to skip executing tests marked as Stochastic. Such tests MAY sometimes fail even though the impl
  - maxSupportedSubscribers
```
public long maxSupportedSubscribers()
```
    Describes the tested implementation in terms of how many subscribers they can support. Some tests require the Publisher under test to support multiple Subscribers, yet the spec does not require all publishers to be able to do so, thus – if an implementation supports only a limited number of subscribers (e.g. only 1 subscriber, also known as "no fanout") you MUST return that number from this method by overriding it.
  - setUp
```
public void setUp()
           throws java.lang.Exception
```
    Throws:
    
    java.lang.Exception
  - createPublisher
```
public org.reactivestreams.Publisher<T> createPublisher(long elements)
```
  - required_validate_maxElementsFromPublisher
```
public void required_validate_maxElementsFromPublisher()
                                                throws java.lang.Exception
```
    Specified by:
    
    required_validate_maxElementsFromPublisher in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Exception
  - required_validate_boundedDepthOfOnNextAndRequestRecursion
```
public void required_validate_boundedDepthOfOnNextAndRequestRecursion()
                                                               throws java.lang.Exception
```
    Specified by:
    
    required_validate_boundedDepthOfOnNextAndRequestRecursion in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Exception
  - required_createPublisher1MustProduceAStreamOfExactly1Element
```
public void required_createPublisher1MustProduceAStreamOfExactly1Element()
                                                                  throws java.lang.Throwable
```
    Specified by:
    
    required_createPublisher1MustProduceAStreamOfExactly1Element in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_createPublisher3MustProduceAStreamOfExactly3Elements
```
public void required_createPublisher3MustProduceAStreamOfExactly3Elements()
                                                                   throws java.lang.Throwable
```
    Specified by:
    
    required_createPublisher3MustProduceAStreamOfExactly3Elements in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec101_subscriptionRequestMustResultInTheCorrectNumberOfProducedElements
```
public void required_spec101_subscriptionRequestMustResultInTheCorrectNumberOfProducedElements()
                                                                                        throws java.lang.Throwable
```
    Specified by:
    
    required_spec101_subscriptionRequestMustResultInTheCorrectNumberOfProducedElements in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec102_maySignalLessThanRequestedAndTerminateSubscription
```
public void required_spec102_maySignalLessThanRequestedAndTerminateSubscription()
                                                                         throws java.lang.Throwable
```
    Specified by:
    
    required_spec102_maySignalLessThanRequestedAndTerminateSubscription in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - stochastic_spec103_mustSignalOnMethodsSequentially
```
public void stochastic_spec103_mustSignalOnMethodsSequentially()
                                                        throws java.lang.Throwable
```
    Specified by:
    
    stochastic_spec103_mustSignalOnMethodsSequentially in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - optional_spec104_mustSignalOnErrorWhenFails
```
public void optional_spec104_mustSignalOnErrorWhenFails()
                                                 throws java.lang.Throwable
```
    Specified by:
    
    optional_spec104_mustSignalOnErrorWhenFails in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec105_mustSignalOnCompleteWhenFiniteStreamTerminates
```
public void required_spec105_mustSignalOnCompleteWhenFiniteStreamTerminates()
                                                                     throws java.lang.Throwable
```
    Specified by:
    
    required_spec105_mustSignalOnCompleteWhenFiniteStreamTerminates in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - optional_spec105_emptyStreamMustTerminateBySignallingOnComplete
```
public void optional_spec105_emptyStreamMustTerminateBySignallingOnComplete()
                                                                     throws java.lang.Throwable
```
    Specified by:
    
    optional_spec105_emptyStreamMustTerminateBySignallingOnComplete in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec106_mustConsiderSubscriptionCancelledAfterOnErrorOrOnCompleteHasBeenCalled
```
public void untested_spec106_mustConsiderSubscriptionCancelledAfterOnErrorOrOnCompleteHasBeenCalled()
                                                                                             throws java.lang.Throwable
```
    Specified by:
    
    untested_spec106_mustConsiderSubscriptionCancelledAfterOnErrorOrOnCompleteHasBeenCalled in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec107_mustNotEmitFurtherSignalsOnceOnCompleteHasBeenSignalled
```
public void required_spec107_mustNotEmitFurtherSignalsOnceOnCompleteHasBeenSignalled()
                                                                              throws java.lang.Throwable
```
    Specified by:
    
    required_spec107_mustNotEmitFurtherSignalsOnceOnCompleteHasBeenSignalled in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec107_mustNotEmitFurtherSignalsOnceOnErrorHasBeenSignalled
```
public void untested_spec107_mustNotEmitFurtherSignalsOnceOnErrorHasBeenSignalled()
                                                                           throws java.lang.Throwable
```
    Specified by:
    
    untested_spec107_mustNotEmitFurtherSignalsOnceOnErrorHasBeenSignalled in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec108_possiblyCanceledSubscriptionShouldNotReceiveOnErrorOrOnCompleteSignals
```
public void untested_spec108_possiblyCanceledSubscriptionShouldNotReceiveOnErrorOrOnCompleteSignals()
                                                                                             throws java.lang.Throwable
```
    Specified by:
    
    untested_spec108_possiblyCanceledSubscriptionShouldNotReceiveOnErrorOrOnCompleteSignals in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec109_subscribeShouldNotThrowNonFatalThrowable
```
public void untested_spec109_subscribeShouldNotThrowNonFatalThrowable()
                                                               throws java.lang.Throwable
```
    Specified by:
    
    untested_spec109_subscribeShouldNotThrowNonFatalThrowable in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec109_subscribeThrowNPEOnNullSubscriber
```
public void required_spec109_subscribeThrowNPEOnNullSubscriber()
                                                        throws java.lang.Throwable
```
    Specified by:
    
    required_spec109_subscribeThrowNPEOnNullSubscriber in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec109_mayRejectCallsToSubscribeIfPublisherIsUnableOrUnwillingToServeThemRejectionMustTriggerOnErrorAfterOnSubscribe
```
public void required_spec109_mayRejectCallsToSubscribeIfPublisherIsUnableOrUnwillingToServeThemRejectionMustTriggerOnErrorAfterOnSubscribe()
                                                                                                                                    throws java.lang.Throwable
```
    Specified by:
    
    required_spec109_mayRejectCallsToSubscribeIfPublisherIsUnableOrUnwillingToServeThemRejectionMustTriggerOnErrorAfterOnSubscribe in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec109_mustIssueOnSubscribeForNonNullSubscriber
```
public void required_spec109_mustIssueOnSubscribeForNonNullSubscriber()
                                                               throws java.lang.Throwable
```
    Specified by:
    
    required_spec109_mustIssueOnSubscribeForNonNullSubscriber in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec110_rejectASubscriptionRequestIfTheSameSubscriberSubscribesTwice
```
public void untested_spec110_rejectASubscriptionRequestIfTheSameSubscriberSubscribesTwice()
                                                                                   throws java.lang.Throwable
```
    Specified by:
    
    untested_spec110_rejectASubscriptionRequestIfTheSameSubscriberSubscribesTwice in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - optional_spec111_maySupportMultiSubscribe
```
public void optional_spec111_maySupportMultiSubscribe()
                                               throws java.lang.Throwable
```
    Specified by:
    
    optional_spec111_maySupportMultiSubscribe in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingOneByOne
```
public void optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingOneByOne()
                                                                                                                       throws java.lang.Throwable
```
    Specified by:
    
    optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingOneByOne in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfront
```
public void optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfront()
                                                                                                                          throws java.lang.Throwable
```
    Specified by:
    
    optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfront in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfrontAndCompleteAsExpected
```
public void optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfrontAndCompleteAsExpected()
                                                                                                                                               throws java.lang.Throwable
```
    Specified by:
    
    optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfrontAndCompleteAsExpected in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec302_mustAllowSynchronousRequestCallsFromOnNextAndOnSubscribe
```
public void required_spec302_mustAllowSynchronousRequestCallsFromOnNextAndOnSubscribe()
                                                                               throws java.lang.Throwable
```
    Specified by:
    
    required_spec302_mustAllowSynchronousRequestCallsFromOnNextAndOnSubscribe in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec303_mustNotAllowUnboundedRecursion
```
public void required_spec303_mustNotAllowUnboundedRecursion()
                                                     throws java.lang.Throwable
```
    Specified by:
    
    required_spec303_mustNotAllowUnboundedRecursion in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec304_requestShouldNotPerformHeavyComputations
```
public void untested_spec304_requestShouldNotPerformHeavyComputations()
                                                               throws java.lang.Exception
```
    Specified by:
    
    untested_spec304_requestShouldNotPerformHeavyComputations in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Exception
  - untested_spec305_cancelMustNotSynchronouslyPerformHeavyCompuatation
```
public void untested_spec305_cancelMustNotSynchronouslyPerformHeavyCompuatation()
                                                                         throws java.lang.Exception
```
    Specified by:
    
    untested_spec305_cancelMustNotSynchronouslyPerformHeavyCompuatation in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Exception
  - required_spec306_afterSubscriptionIsCancelledRequestMustBeNops
```
public void required_spec306_afterSubscriptionIsCancelledRequestMustBeNops()
                                                                    throws java.lang.Throwable
```
    Specified by:
    
    required_spec306_afterSubscriptionIsCancelledRequestMustBeNops in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec307_afterSubscriptionIsCancelledAdditionalCancelationsMustBeNops
```
public void required_spec307_afterSubscriptionIsCancelledAdditionalCancelationsMustBeNops()
                                                                                   throws java.lang.Throwable
```
    Specified by:
    
    required_spec307_afterSubscriptionIsCancelledAdditionalCancelationsMustBeNops in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec309_requestZeroMustSignalIllegalArgumentException
```
public void required_spec309_requestZeroMustSignalIllegalArgumentException()
                                                                    throws java.lang.Throwable
```
    Specified by:
    
    required_spec309_requestZeroMustSignalIllegalArgumentException in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec309_requestNegativeNumberMustSignalIllegalArgumentException
```
public void required_spec309_requestNegativeNumberMustSignalIllegalArgumentException()
                                                                              throws java.lang.Throwable
```
    Specified by:
    
    required_spec309_requestNegativeNumberMustSignalIllegalArgumentException in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec312_cancelMustMakeThePublisherToEventuallyStopSignaling
```
public void required_spec312_cancelMustMakeThePublisherToEventuallyStopSignaling()
                                                                          throws java.lang.Throwable
```
    Specified by:
    
    required_spec312_cancelMustMakeThePublisherToEventuallyStopSignaling in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec313_cancelMustMakeThePublisherEventuallyDropAllReferencesToTheSubscriber
```
public void required_spec313_cancelMustMakeThePublisherEventuallyDropAllReferencesToTheSubscriber()
                                                                                           throws java.lang.Throwable
```
    Specified by:
    
    required_spec313_cancelMustMakeThePublisherEventuallyDropAllReferencesToTheSubscriber in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec317_mustSupportAPendingElementCountUpToLongMaxValue
```
public void required_spec317_mustSupportAPendingElementCountUpToLongMaxValue()
                                                                      throws java.lang.Throwable
```
    Specified by:
    
    required_spec317_mustSupportAPendingElementCountUpToLongMaxValue in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec317_mustSupportACumulativePendingElementCountUpToLongMaxValue
```
public void required_spec317_mustSupportACumulativePendingElementCountUpToLongMaxValue()
                                                                                throws java.lang.Throwable
```
    Specified by:
    
    required_spec317_mustSupportACumulativePendingElementCountUpToLongMaxValue in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec317_mustNotSignalOnErrorWhenPendingAboveLongMaxValue
```
public void required_spec317_mustNotSignalOnErrorWhenPendingAboveLongMaxValue()
                                                                       throws java.lang.Throwable
```
    Specified by:
    
    required_spec317_mustNotSignalOnErrorWhenPendingAboveLongMaxValue in interface PublisherVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec104_mustCallOnErrorOnAllItsSubscribersIfItEncountersANonRecoverableError
```
public void required_spec104_mustCallOnErrorOnAllItsSubscribersIfItEncountersANonRecoverableError()
                                                                                           throws java.lang.Throwable
```
    Throws:
    
    java.lang.Throwable
  - createSubscriber
```
public org.reactivestreams.Subscriber<T> createSubscriber(SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> probe)
```
  - mustImmediatelyPassOnOnErrorEventsReceivedFromItsUpstreamToItsDownstream
```
public void mustImmediatelyPassOnOnErrorEventsReceivedFromItsUpstreamToItsDownstream()
                                                                              throws java.lang.Exception
```
    Throws:
    
    java.lang.Exception
  - required_exerciseWhiteboxHappyPath
```
public void required_exerciseWhiteboxHappyPath()
                                        throws java.lang.Throwable
```
    Specified by:
    
    required_exerciseWhiteboxHappyPath in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec201_mustSignalDemandViaSubscriptionRequest
```
public void required_spec201_mustSignalDemandViaSubscriptionRequest()
                                                             throws java.lang.Throwable
```
    Specified by:
    
    required_spec201_mustSignalDemandViaSubscriptionRequest in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec202_shouldAsynchronouslyDispatch
```
public void untested_spec202_shouldAsynchronouslyDispatch()
                                                   throws java.lang.Exception
```
    Specified by:
    
    untested_spec202_shouldAsynchronouslyDispatch in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete
```
public void required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete()
                                                                              throws java.lang.Throwable
```
    Specified by:
    
    required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnError
```
public void required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnError()
                                                                           throws java.lang.Throwable
```
    Specified by:
    
    required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnError in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec204_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError
```
public void untested_spec204_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError()
                                                                                                throws java.lang.Exception
```
    Specified by:
    
    untested_spec204_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - required_spec205_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal
```
public void required_spec205_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal()
                                                                                                                throws java.lang.Throwable
```
    Specified by:
    
    required_spec205_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec206_mustCallSubscriptionCancelIfItIsNoLongerValid
```
public void untested_spec206_mustCallSubscriptionCancelIfItIsNoLongerValid()
                                                                    throws java.lang.Exception
```
    Specified by:
    
    untested_spec206_mustCallSubscriptionCancelIfItIsNoLongerValid in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - untested_spec207_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization
```
public void untested_spec207_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization()
                                                                                                               throws java.lang.Exception
```
    Specified by:
    
    untested_spec207_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - required_spec208_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel
```
public void required_spec208_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel()
                                                                                              throws java.lang.Throwable
```
    Specified by:
    
    required_spec208_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall
```
public void required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall()
                                                                                        throws java.lang.Throwable
```
    Specified by:
    
    required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall
```
public void required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall()
                                                                                           throws java.lang.Throwable
```
    Specified by:
    
    required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall
```
public void required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall()
                                                                                     throws java.lang.Throwable
```
    Specified by:
    
    required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall
```
public void required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall()
                                                                                        throws java.lang.Throwable
```
    Specified by:
    
    required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec211_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents
```
public void untested_spec211_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents()
                                                                                                         throws java.lang.Exception
```
    Specified by:
    
    untested_spec211_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - untested_spec212_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality_specViolation
```
public void untested_spec212_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality_specViolation()
                                                                                            throws java.lang.Throwable
```
    Specified by:
    
    untested_spec212_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality_specViolation in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec213_failingOnSignalInvocation
```
public void untested_spec213_failingOnSignalInvocation()
                                                throws java.lang.Exception
```
    Specified by:
    
    untested_spec213_failingOnSignalInvocation in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - required_spec213_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull
```
public void required_spec213_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull()
                                                                                     throws java.lang.Throwable
```
    Specified by:
    
    required_spec213_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec213_onNext_mustThrowNullPointerExceptionWhenParametersAreNull
```
public void required_spec213_onNext_mustThrowNullPointerExceptionWhenParametersAreNull()
                                                                                throws java.lang.Throwable
```
    Specified by:
    
    required_spec213_onNext_mustThrowNullPointerExceptionWhenParametersAreNull in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - required_spec213_onError_mustThrowNullPointerExceptionWhenParametersAreNull
```
public void required_spec213_onError_mustThrowNullPointerExceptionWhenParametersAreNull()
                                                                                 throws java.lang.Throwable
```
    Specified by:
    
    required_spec213_onError_mustThrowNullPointerExceptionWhenParametersAreNull in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec301_mustNotBeCalledOutsideSubscriberContext
```
public void untested_spec301_mustNotBeCalledOutsideSubscriberContext()
                                                              throws java.lang.Exception
```
    Specified by:
    
    untested_spec301_mustNotBeCalledOutsideSubscriberContext in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - required_spec308_requestMustRegisterGivenNumberElementsToBeProduced
```
public void required_spec308_requestMustRegisterGivenNumberElementsToBeProduced()
                                                                         throws java.lang.Throwable
```
    Specified by:
    
    required_spec308_requestMustRegisterGivenNumberElementsToBeProduced in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Throwable
  - untested_spec310_requestMaySynchronouslyCallOnNextOnSubscriber
```
public void untested_spec310_requestMaySynchronouslyCallOnNextOnSubscriber()
                                                                    throws java.lang.Exception
```
    Specified by:
    
    untested_spec310_requestMaySynchronouslyCallOnNextOnSubscriber in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - untested_spec311_requestMaySynchronouslyCallOnCompleteOrOnError
```
public void untested_spec311_requestMaySynchronouslyCallOnCompleteOrOnError()
                                                                     throws java.lang.Exception
```
    Specified by:
    
    untested_spec311_requestMaySynchronouslyCallOnCompleteOrOnError in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - untested_spec314_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists
```
public void untested_spec314_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists()
                                                                                      throws java.lang.Exception
```
    Specified by:
    
    untested_spec314_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - untested_spec315_cancelMustNotThrowExceptionAndMustSignalOnError
```
public void untested_spec315_cancelMustNotThrowExceptionAndMustSignalOnError()
                                                                      throws java.lang.Exception
```
    Specified by:
    
    untested_spec315_cancelMustNotThrowExceptionAndMustSignalOnError in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - untested_spec316_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber
```
public void untested_spec316_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber()
                                                                              throws java.lang.Exception
```
    Specified by:
    
    untested_spec316_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber in interface SubscriberWhiteboxVerificationRules
    
    Throws:
    
    java.lang.Exception
  - required_mustRequestFromUpstreamForElementsThatHaveBeenRequestedLongAgo
```
public void required_mustRequestFromUpstreamForElementsThatHaveBeenRequestedLongAgo()
                                                                             throws java.lang.Throwable
```
    Throws:
    
    java.lang.Throwable
  - notVerified
```
public void notVerified()
```
  - notVerified
```
public void notVerified(java.lang.String message)
```
  - optionalMultipleSubscribersTest
```
public void optionalMultipleSubscribersTest(long requiredSubscribersSupport,
                                            Function<java.lang.Long,IdentityProcessorVerification.TestSetup> body)
                                     throws java.lang.Throwable
```
    Test for feature that REQUIRES multiple subscribers to be supported by Publisher.
    
    Throws:
    
    java.lang.Throwable

Class IdentityProcessorVerification<T>

Nested Class Summary

Constructor Summary

Method Summary

Methods inherited from class org.reactivestreams.tck.WithHelperPublisher

Methods inherited from class java.lang.Object

Constructor Detail

IdentityProcessorVerification

IdentityProcessorVerification

IdentityProcessorVerification

Method Detail

createIdentityProcessor

createFailedPublisher

maxElementsFromPublisher

boundedDepthOfOnNextAndRequestRecursion

skipStochasticTests

maxSupportedSubscribers

setUp

createPublisher

required_validate_maxElementsFromPublisher

required_validate_boundedDepthOfOnNextAndRequestRecursion

required_createPublisher1MustProduceAStreamOfExactly1Element

required_createPublisher3MustProduceAStreamOfExactly3Elements

required_spec101_subscriptionRequestMustResultInTheCorrectNumberOfProducedElements

required_spec102_maySignalLessThanRequestedAndTerminateSubscription

stochastic_spec103_mustSignalOnMethodsSequentially

optional_spec104_mustSignalOnErrorWhenFails

required_spec105_mustSignalOnCompleteWhenFiniteStreamTerminates

optional_spec105_emptyStreamMustTerminateBySignallingOnComplete

untested_spec106_mustConsiderSubscriptionCancelledAfterOnErrorOrOnCompleteHasBeenCalled

required_spec107_mustNotEmitFurtherSignalsOnceOnCompleteHasBeenSignalled

untested_spec107_mustNotEmitFurtherSignalsOnceOnErrorHasBeenSignalled

untested_spec108_possiblyCanceledSubscriptionShouldNotReceiveOnErrorOrOnCompleteSignals

untested_spec109_subscribeShouldNotThrowNonFatalThrowable

required_spec109_subscribeThrowNPEOnNullSubscriber

required_spec109_mayRejectCallsToSubscribeIfPublisherIsUnableOrUnwillingToServeThemRejectionMustTriggerOnErrorAfterOnSubscribe

required_spec109_mustIssueOnSubscribeForNonNullSubscriber

untested_spec110_rejectASubscriptionRequestIfTheSameSubscriberSubscribesTwice

optional_spec111_maySupportMultiSubscribe

optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingOneByOne

optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfront

optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfrontAndCompleteAsExpected

required_spec302_mustAllowSynchronousRequestCallsFromOnNextAndOnSubscribe

required_spec303_mustNotAllowUnboundedRecursion

untested_spec304_requestShouldNotPerformHeavyComputations

untested_spec305_cancelMustNotSynchronouslyPerformHeavyCompuatation

required_spec306_afterSubscriptionIsCancelledRequestMustBeNops

required_spec307_afterSubscriptionIsCancelledAdditionalCancelationsMustBeNops

required_spec309_requestZeroMustSignalIllegalArgumentException

required_spec309_requestNegativeNumberMustSignalIllegalArgumentException

required_spec312_cancelMustMakeThePublisherToEventuallyStopSignaling

required_spec313_cancelMustMakeThePublisherEventuallyDropAllReferencesToTheSubscriber

required_spec317_mustSupportAPendingElementCountUpToLongMaxValue

required_spec317_mustSupportACumulativePendingElementCountUpToLongMaxValue

required_spec317_mustNotSignalOnErrorWhenPendingAboveLongMaxValue

required_spec104_mustCallOnErrorOnAllItsSubscribersIfItEncountersANonRecoverableError

createSubscriber

mustImmediatelyPassOnOnErrorEventsReceivedFromItsUpstreamToItsDownstream

required_exerciseWhiteboxHappyPath

required_spec201_mustSignalDemandViaSubscriptionRequest

untested_spec202_shouldAsynchronouslyDispatch

required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete

required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnError

untested_spec204_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError

required_spec205_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal

untested_spec206_mustCallSubscriptionCancelIfItIsNoLongerValid

untested_spec207_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization

required_spec208_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel

required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall

required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall

required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall

required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall

untested_spec211_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents

untested_spec212_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality_specViolation

untested_spec213_failingOnSignalInvocation

required_spec213_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull

required_spec213_onNext_mustThrowNullPointerExceptionWhenParametersAreNull

required_spec213_onError_mustThrowNullPointerExceptionWhenParametersAreNull

untested_spec301_mustNotBeCalledOutsideSubscriberContext

required_spec308_requestMustRegisterGivenNumberElementsToBeProduced