org.reactivestreams.tck

Class PublisherVerification<T>

java.lang.Object

org.reactivestreams.tck.PublisherVerification<T>

public abstract class PublisherVerification<T>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
PublisherVerification(TestEnvironment env, long publisherShutdownTimeoutMillis)

Method Summary

Modifier and Type	Method and Description
void	activePublisherTest(int elements, org.reactivestreams.tck.PublisherVerification.PublisherTestRun<T> body)
void	completedPublisherTest(org.reactivestreams.tck.PublisherVerification.PublisherTestRun<T> body)
abstract org.reactivestreams.spi.Publisher<T>	createCompletedStatePublisher() Return a Publisher in completed state in order to run additional tests on it, or null in order to skip them.
abstract org.reactivestreams.spi.Publisher<T>	createErrorStatePublisher() Return a Publisher in error state in order to run additional tests on it, or null in order to skip them.
abstract org.reactivestreams.spi.Publisher<T>	createPublisher(int elements) This is the main method you must implement in your test incarnation.
void	createPublisher3MustProduceAStreamOfExactly3Elements()
void	errorPublisherTest(org.reactivestreams.tck.PublisherVerification.PublisherTestRun<T> body)
void	mustCallOnCompleteOnASubscriberAfterHavingProducedTheFinalStreamElementToIt()
void	mustCallOnErrorOnAllItsSubscribersIfItEncountersANonRecoverableError()
void	mustNotCallOnCompleteOrOnErrorMoreThanOncePerSubscriber()
void	mustNotCallOnNextAfterHavingIssuedAnOnCompleteOrOnErrorCallOnASubscriber()
void	mustProduceTheSameElementsInTheSameSequenceForAllItsSubscribers()
void	mustStartProducingWithTheOldestStillAvailableElementForASubscriber()
void	mustSupportAPendingElementCountUpToLongMaxValue()
void	onSubscriptionCancelThePublisherMustEventuallyCeaseToCallAnyMethodsOnTheSubscriber()
void	onSubscriptionCancelThePublisherMustEventuallyDropAllReferencesToTheSubscriber()
void	potentiallyPendingTest(org.reactivestreams.spi.Publisher<T> pub, org.reactivestreams.tck.PublisherVerification.PublisherTestRun<T> body)
void	publisherSubscribeWhenActiveMustCallOnSubscribeFirst()
void	publisherSubscribeWhenActiveMustRejectDoubleSubscription()
void	publisherSubscribeWhenCompletedMustTriggerOnCompleteAndNotOnSubscribe()
void	publisherSubscribeWhenInErrorStateMustTriggerOnErrorAndNotOnSubscribe()
void	publisherSubscribeWhenInShutDownStateMustTriggerOnErrorAndNotOnSubscribe()
void	subscriptionCancelWhenCancelledMustIgnoreCall()
void	subscriptionRequestMoreMustResultInTheCorrectNumberOfProducedElements()
void	subscriptionRequestMoreMustThrowIfArgumentIsNonPositive()
void	subscriptionRequestMoreWhenCancelledMustIgnoreTheCall()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PublisherVerification

public PublisherVerification(TestEnvironment env,
                             long publisherShutdownTimeoutMillis)

Method Detail

createPublisher

public abstract org.reactivestreams.spi.Publisher<T> createPublisher(int 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 zero the produced stream must be infinite.

createCompletedStatePublisher

public abstract org.reactivestreams.spi.Publisher<T> createCompletedStatePublisher()

Return a Publisher in completed state in order to run additional tests on it, or null in order to skip them.

createErrorStatePublisher

public abstract org.reactivestreams.spi.Publisher<T> createErrorStatePublisher()

Return a Publisher in error state in order to run additional tests on it, or null in order to skip them.

createPublisher3MustProduceAStreamOfExactly3Elements

public void createPublisher3MustProduceAStreamOfExactly3Elements()
                                                          throws java.lang.Throwable

Throws:

java.lang.Throwable

publisherSubscribeWhenCompletedMustTriggerOnCompleteAndNotOnSubscribe

public void publisherSubscribeWhenCompletedMustTriggerOnCompleteAndNotOnSubscribe()
                                                                           throws java.lang.Throwable

Throws:

java.lang.Throwable

publisherSubscribeWhenInErrorStateMustTriggerOnErrorAndNotOnSubscribe

public void publisherSubscribeWhenInErrorStateMustTriggerOnErrorAndNotOnSubscribe()
                                                                           throws java.lang.Throwable

Throws:

java.lang.Throwable

publisherSubscribeWhenInShutDownStateMustTriggerOnErrorAndNotOnSubscribe

public void publisherSubscribeWhenInShutDownStateMustTriggerOnErrorAndNotOnSubscribe()
                                                                              throws java.lang.Throwable

Throws:

java.lang.Throwable

publisherSubscribeWhenActiveMustCallOnSubscribeFirst

public void publisherSubscribeWhenActiveMustCallOnSubscribeFirst()
                                                          throws java.lang.Throwable

Throws:

java.lang.Throwable

publisherSubscribeWhenActiveMustRejectDoubleSubscription

public void publisherSubscribeWhenActiveMustRejectDoubleSubscription()
                                                              throws java.lang.Throwable

Throws:

java.lang.Throwable

subscriptionRequestMoreWhenCancelledMustIgnoreTheCall

public void subscriptionRequestMoreWhenCancelledMustIgnoreTheCall()
                                                           throws java.lang.Throwable

Throws:

java.lang.Throwable

subscriptionRequestMoreMustResultInTheCorrectNumberOfProducedElements

public void subscriptionRequestMoreMustResultInTheCorrectNumberOfProducedElements()
                                                                           throws java.lang.Throwable

Throws:

java.lang.Throwable

subscriptionRequestMoreMustThrowIfArgumentIsNonPositive

public void subscriptionRequestMoreMustThrowIfArgumentIsNonPositive()
                                                             throws java.lang.Throwable

Throws:

java.lang.Throwable

subscriptionCancelWhenCancelledMustIgnoreCall

public void subscriptionCancelWhenCancelledMustIgnoreCall()
                                                   throws java.lang.Throwable

Throws:

java.lang.Throwable

onSubscriptionCancelThePublisherMustEventuallyCeaseToCallAnyMethodsOnTheSubscriber

public void onSubscriptionCancelThePublisherMustEventuallyCeaseToCallAnyMethodsOnTheSubscriber()
                                                                                        throws java.lang.Throwable

Throws:

java.lang.Throwable

onSubscriptionCancelThePublisherMustEventuallyDropAllReferencesToTheSubscriber

public void onSubscriptionCancelThePublisherMustEventuallyDropAllReferencesToTheSubscriber()
                                                                                    throws java.lang.Throwable

Throws:

java.lang.Throwable

mustNotCallOnNextAfterHavingIssuedAnOnCompleteOrOnErrorCallOnASubscriber

public void mustNotCallOnNextAfterHavingIssuedAnOnCompleteOrOnErrorCallOnASubscriber()

mustProduceTheSameElementsInTheSameSequenceForAllItsSubscribers

public void mustProduceTheSameElementsInTheSameSequenceForAllItsSubscribers()
                                                                     throws java.lang.Throwable

Throws:

java.lang.Throwable

mustSupportAPendingElementCountUpToLongMaxValue

public void mustSupportAPendingElementCountUpToLongMaxValue()

mustCallOnCompleteOnASubscriberAfterHavingProducedTheFinalStreamElementToIt

public void mustCallOnCompleteOnASubscriberAfterHavingProducedTheFinalStreamElementToIt()
                                                                                 throws java.lang.Throwable

Throws:

java.lang.Throwable

mustStartProducingWithTheOldestStillAvailableElementForASubscriber

public void mustStartProducingWithTheOldestStillAvailableElementForASubscriber()

mustCallOnErrorOnAllItsSubscribersIfItEncountersANonRecoverableError

public void mustCallOnErrorOnAllItsSubscribersIfItEncountersANonRecoverableError()

mustNotCallOnCompleteOrOnErrorMoreThanOncePerSubscriber

public void mustNotCallOnCompleteOrOnErrorMoreThanOncePerSubscriber()

activePublisherTest

public void activePublisherTest(int elements,
                                org.reactivestreams.tck.PublisherVerification.PublisherTestRun<T> body)
                         throws java.lang.Throwable

Throws:

java.lang.Throwable

completedPublisherTest

public void completedPublisherTest(org.reactivestreams.tck.PublisherVerification.PublisherTestRun<T> body)
                            throws java.lang.Throwable

Throws:

java.lang.Throwable

errorPublisherTest

public void errorPublisherTest(org.reactivestreams.tck.PublisherVerification.PublisherTestRun<T> body)
                        throws java.lang.Throwable

Throws:

java.lang.Throwable

potentiallyPendingTest

public void potentiallyPendingTest(org.reactivestreams.spi.Publisher<T> pub,
                                   org.reactivestreams.tck.PublisherVerification.PublisherTestRun<T> body)
                            throws java.lang.Throwable

Throws:

java.lang.Throwable