PublisherVerification (reactive-streams-tck 1.0.0 API)

java.lang.Object
- org.reactivestreams.tck.PublisherVerification<T>

All Implemented Interfaces:

PublisherVerificationRules
```
public abstract class PublisherVerification<T>
extends java.lang.Object
implements PublisherVerificationRules
```
Provides tests for verifying Publisher specification rules.

See Also:

Publisher

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static interface PublisherVerification.PublisherTestRun<T>

Nested Classes
Modifier and Type	Class and Description
`static interface`	`PublisherVerification.PublisherTestRun<T>`

Field Summary

Fields
Modifier and Type Field and Description

static java.lang.String SKIPPING_NO_ERROR_PUBLISHER_AVAILABLE

static java.lang.String SKIPPING_OPTIONAL_TEST_FAILED

Fields
Modifier and Type	Field and Description
`static java.lang.String`	`SKIPPING_NO_ERROR_PUBLISHER_AVAILABLE`
`static java.lang.String`	`SKIPPING_OPTIONAL_TEST_FAILED`

Constructor Summary

Constructors
Constructor and Description
`PublisherVerification(TestEnvironment env)` Constructs a new verification class using the given env and configuration.
`PublisherVerification(TestEnvironment env, long publisherReferenceGCTimeoutMillis)` Constructs a new verification class using the given env and configuration.

Method Summary

All Methods Static Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`activePublisherTest(long elements, boolean completionSignalRequired, PublisherVerification.PublisherTestRun<T> body)` Test for feature that SHOULD/MUST be implemented, using a live publisher.
`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.Publisher<T>`	`createPublisher(long elements)` This is the main method you must implement in your test incarnation.
`static long`	`envPublisherReferenceGCTimeoutMillis()` Tries to parse the env variable `PUBLISHER_REFERENCE_GC_TIMEOUT_MILLIS` as long and returns the value if present, OR its default value (`DEFAULT_PUBLISHER_REFERENCE_GC_TIMEOUT_MILLIS`).
`long`	`maxElementsFromPublisher()` Override and return lower value if your Publisher is only able to produce a known number of elements.
`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`	`optionalActivePublisherTest(long elements, boolean completionSignalRequired, PublisherVerification.PublisherTestRun<T> body)` Test for feature that MAY be implemented.
`void`	`potentiallyPendingTest(org.reactivestreams.Publisher<T> pub, PublisherVerification.PublisherTestRun<T> body)`
`void`	`potentiallyPendingTest(org.reactivestreams.Publisher<T> pub, PublisherVerification.PublisherTestRun<T> body, java.lang.String message)`
`long`	`publisherUnableToSignalOnComplete()` Return this value from `maxElementsFromPublisher()` to mark that the given `Publisher`, is not able to signal completion.
`void`	`required_createPublisher1MustProduceAStreamOfExactly1Element()`
`void`	`required_createPublisher3MustProduceAStreamOfExactly3Elements()`
`void`	`required_spec101_subscriptionRequestMustResultInTheCorrectNumberOfProducedElements()`
`void`	`required_spec102_maySignalLessThanRequestedAndTerminateSubscription()`
`void`	`required_spec105_mustSignalOnCompleteWhenFiniteStreamTerminates()`
`void`	`required_spec107_mustNotEmitFurtherSignalsOnceOnCompleteHasBeenSignalled()`
`void`	`required_spec109_mayRejectCallsToSubscribeIfPublisherIsUnableOrUnwillingToServeThemRejectionMustTriggerOnErrorAfterOnSubscribe()`
`void`	`required_spec109_mustIssueOnSubscribeForNonNullSubscriber()`
`void`	`required_spec109_subscribeThrowNPEOnNullSubscriber()`
`void`	`required_spec302_mustAllowSynchronousRequestCallsFromOnNextAndOnSubscribe()`
`void`	`required_spec303_mustNotAllowUnboundedRecursion()`
`void`	`required_spec306_afterSubscriptionIsCancelledRequestMustBeNops()`
`void`	`required_spec307_afterSubscriptionIsCancelledAdditionalCancelationsMustBeNops()`
`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`	`stochasticTest(int n, Function<java.lang.Integer,java.lang.Void> body)` Executes a given test body `n` times.
`void`	`untested_spec106_mustConsiderSubscriptionCancelledAfterOnErrorOrOnCompleteHasBeenCalled()`
`void`	`untested_spec107_mustNotEmitFurtherSignalsOnceOnErrorHasBeenSignalled()`
`void`	`untested_spec108_possiblyCanceledSubscriptionShouldNotReceiveOnErrorOrOnCompleteSignals()`
`void`	`untested_spec109_subscribeShouldNotThrowNonFatalThrowable()`
`void`	`untested_spec110_rejectASubscriptionRequestIfTheSameSubscriberSubscribesTwice()`
`void`	`untested_spec304_requestShouldNotPerformHeavyComputations()`
`void`	`untested_spec305_cancelMustNotSynchronouslyPerformHeavyCompuatation()`
`void`	`whenHasErrorPublisherTest(PublisherVerification.PublisherTestRun<T> body)` Additional test for Publisher in error state

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

- Field Detail
  - SKIPPING_NO_ERROR_PUBLISHER_AVAILABLE
```
public static final java.lang.String SKIPPING_NO_ERROR_PUBLISHER_AVAILABLE
```
    See Also:
    
    Constant Field Values
  - SKIPPING_OPTIONAL_TEST_FAILED
```
public static final java.lang.String SKIPPING_OPTIONAL_TEST_FAILED
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - PublisherVerification
```
public PublisherVerification(TestEnvironment env,
                             long publisherReferenceGCTimeoutMillis)
```
    Constructs a new verification class using the given env and configuration.
    
    Parameters:
    
    publisherReferenceGCTimeoutMillis - used to determine after how much time a reference to a Subscriber should be already dropped by the Publisher.
  - PublisherVerification
```
public PublisherVerification(TestEnvironment env)
```
    Constructs a new verification class using the given env and configuration. The value for publisherReferenceGCTimeoutMillis will be obtained by using envPublisherReferenceGCTimeoutMillis().
- Method Detail
  - envPublisherReferenceGCTimeoutMillis
```
public static long envPublisherReferenceGCTimeoutMillis()
```
    Tries to parse the env variable PUBLISHER_REFERENCE_GC_TIMEOUT_MILLIS as long and returns the value if present, OR its default value (DEFAULT_PUBLISHER_REFERENCE_GC_TIMEOUT_MILLIS). This value is used to determine after how much time a reference to a Subscriber should be already dropped by the Publisher.
    
    Throws:
    
    java.lang.IllegalArgumentException - when unable to parse the env variable
  - createPublisher
```
public abstract org.reactivestreams.Publisher<T> createPublisher(long elements)
```
    This is the main method you must implement in your test incarnation. It must create a Publisher for a stream with exactly the given number of elements. If `elements` is `Long.MAX_VALUE` the produced stream must be infinite.
  - 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* (!).
  - 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
  - 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, required_spec303_mustNotAllowUnboundedRecursion()
  - setUp
```
public void setUp()
           throws java.lang.Exception
```
    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_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_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_mustIssueOnSubscribeForNonNullSubscriber
```
public void required_spec109_mustIssueOnSubscribeForNonNullSubscriber()
                                                               throws java.lang.Throwable
```
    Specified by:
    
    required_spec109_mustIssueOnSubscribeForNonNullSubscriber 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
  - 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
  - activePublisherTest
```
public void activePublisherTest(long elements,
                                boolean completionSignalRequired,
                                PublisherVerification.PublisherTestRun<T> body)
                         throws java.lang.Throwable
```
    Test for feature that SHOULD/MUST be implemented, using a live publisher.
    
    Parameters:
    
    elements - the number of elements the Publisher under test must be able to emit to run this test
    
    completionSignalRequired - true if an onComplete signal is required by this test to run. If the tested Publisher is unable to signal completion, tests requireing onComplete signals will be skipped. To signal if your Publisher is able to signal completion see maxElementsFromPublisher().
    
    Throws:
    
    java.lang.Throwable
  - optionalActivePublisherTest
```
public void optionalActivePublisherTest(long elements,
                                        boolean completionSignalRequired,
                                        PublisherVerification.PublisherTestRun<T> body)
                                 throws java.lang.Throwable
```
    Test for feature that MAY be implemented. This test will be marked as SKIPPED if it fails.
    
    Parameters:
    
    elements - the number of elements the Publisher under test must be able to emit to run this test
    
    completionSignalRequired - true if an onComplete signal is required by this test to run. If the tested Publisher is unable to signal completion, tests requireing onComplete signals will be skipped. To signal if your Publisher is able to signal completion see maxElementsFromPublisher().
    
    Throws:
    
    java.lang.Throwable
  - whenHasErrorPublisherTest
```
public void whenHasErrorPublisherTest(PublisherVerification.PublisherTestRun<T> body)
                               throws java.lang.Throwable
```
    Additional test for Publisher in error state
    
    Throws:
    
    java.lang.Throwable
  - potentiallyPendingTest
```
public void potentiallyPendingTest(org.reactivestreams.Publisher<T> pub,
                                   PublisherVerification.PublisherTestRun<T> body)
                            throws java.lang.Throwable
```
    Throws:
    
    java.lang.Throwable
  - potentiallyPendingTest
```
public void potentiallyPendingTest(org.reactivestreams.Publisher<T> pub,
                                   PublisherVerification.PublisherTestRun<T> body,
                                   java.lang.String message)
                            throws java.lang.Throwable
```
    Throws:
    
    java.lang.Throwable
  - stochasticTest
```
public void stochasticTest(int n,
                           Function<java.lang.Integer,java.lang.Void> body)
                    throws java.lang.Throwable
```
    Executes a given test body n times. All the test runs must pass in order for the stochastic test to pass.
    
    Throws:
    
    java.lang.Throwable
  - notVerified
```
public void notVerified()
```
  - publisherUnableToSignalOnComplete
```
public long publisherUnableToSignalOnComplete()
```
    Return this value from maxElementsFromPublisher() to mark that the given Publisher, is not able to signal completion. For example it is strictly a time-bound or unbounded source of data. Returning this value from maxElementsFromPublisher() will result in skipping all TCK tests which require onComplete signals!
  - notVerified
```
public void notVerified(java.lang.String message)
```

Class PublisherVerification<T>

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

SKIPPING_NO_ERROR_PUBLISHER_AVAILABLE

SKIPPING_OPTIONAL_TEST_FAILED

Constructor Detail

PublisherVerification

PublisherVerification

Method Detail

envPublisherReferenceGCTimeoutMillis

createPublisher

createFailedPublisher

maxElementsFromPublisher

skipStochasticTests

boundedDepthOfOnNextAndRequestRecursion

setUp

required_createPublisher1MustProduceAStreamOfExactly1Element

required_createPublisher3MustProduceAStreamOfExactly3Elements

required_validate_maxElementsFromPublisher

required_validate_boundedDepthOfOnNextAndRequestRecursion

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_mustIssueOnSubscribeForNonNullSubscriber

required_spec109_mayRejectCallsToSubscribeIfPublisherIsUnableOrUnwillingToServeThemRejectionMustTriggerOnErrorAfterOnSubscribe

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

activePublisherTest

optionalActivePublisherTest

whenHasErrorPublisherTest

potentiallyPendingTest

potentiallyPendingTest

stochasticTest

notVerified

publisherUnableToSignalOnComplete

notVerified