org.reactivestreams.tck

Class IdentityProcessorVerification<T>

java.lang.Object

org.reactivestreams.tck.IdentityProcessorVerification<T>

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

Constructor Summary

Constructors

Constructor and Description
IdentityProcessorVerification(TestEnvironment env, long publisherShutdownTimeoutMillis) 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 publisherShutdownTimeoutMillis, int testBufferSize)

Method Summary

Modifier and Type	Method and Description
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>	createHelperPublisher(int elements) Helper method required for running the Publisher rules against a Processor.
abstract org.reactivestreams.api.Processor<T,T>	createIdentityProcessor(int bufferSize) This is the main method you must implement in your test incarnation.
org.reactivestreams.spi.Publisher<T>	createPublisher(int elements)
void	createPublisher3MustProduceAStreamOfExactly3Elements()
org.reactivestreams.spi.Subscriber<T>	createSubscriber(org.reactivestreams.tck.SubscriberVerification.SubscriberProbe<T> probe)
void	exerciseHappyPath()
void	mustBePreparedToReceiveAnOnCompleteEventWithAPrecedingSubscriptionRequestMore()
void	mustBePreparedToReceiveAnOnCompleteEventWithoutAPrecedingSubscriptionRequestMore()
void	mustBePreparedToReceiveAnOnErrorEventWithAPrecedingSubscriptionRequestMore()
void	mustBePreparedToReceiveAnOnErrorEventWithoutAPrecedingSubscriptionRequestMore()
void	mustBePreparedToReceiveIncomingElementsFromItsUpstreamEvenIfADownstreamSubscriberHasNotRequestedYet()
void	mustBePreparedToReceiveOneOrMoreOnNextEventsAfterHavingCalledSubscriptionCancel()
void	mustCallOnCompleteOnASubscriberAfterHavingProducedTheFinalStreamElementToIt()
void	mustCallOnErrorOnAllItsSubscribersIfItEncountersANonRecoverableError()
void	mustCallSubscriptionCancelDuringShutdownIfItStillHasAnActiveSubscription()
void	mustCancelItsUpstreamSubscriptionIfItsLastDownstreamSubscriptionHasBeenCancelled()
void	mustEnsureThatAllCallsOnASubscriptionTakePlaceFromTheSameThreadOrProvideExternalSync()
void	mustImmediatelyPassOnOnErrorEventsReceivedFromItsUpstreamToItsDownstream()
void	mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents()
void	mustNotAcceptAnOnSubscribeEventIfItAlreadyHasAnActiveSubscription()
void	mustNotCallOnCompleteOrOnErrorMoreThanOncePerSubscriber()
void	mustNotCallOnNextAfterHavingIssuedAnOnCompleteOrOnErrorCallOnASubscriber()
void	mustProduceTheSameElementsInTheSameSequenceForAllItsSubscribers()
void	mustRequestFromUpstreamForElementsThatHaveBeenRequestedLongAgo()
void	mustStartProducingWithTheOldestStillAvailableElementForASubscriber()
void	mustSupportAPendingElementCountUpToLongMaxValue()
void	mustUnblockTheStreamIfABlockingSubscriptionHasBeenCancelled()
void	onCompleteAndOnErrorMustAsynchronouslyScheduleAnEvent()
void	onSubscribeAndOnNextMustAsynchronouslyScheduleAnEvent()
void	onSubscriptionCancelThePublisherMustEventuallyCeaseToCallAnyMethodsOnTheSubscriber()
void	onSubscriptionCancelThePublisherMustEventuallyDropAllReferencesToTheSubscriber()
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

IdentityProcessorVerification

public IdentityProcessorVerification(TestEnvironment env,
                                     long publisherShutdownTimeoutMillis)

Test class must specify the expected time it takes for the publisher to shut itself down when the the last downstream Subscription is cancelled. Used by `publisherSubscribeWhenInShutDownStateMustTriggerOnErrorAndNotOnSubscribe`.

IdentityProcessorVerification

public IdentityProcessorVerification(TestEnvironment env,
                                     long publisherShutdownTimeoutMillis,
                                     int testBufferSize)

Method Detail

createIdentityProcessor

public abstract org.reactivestreams.api.Processor<T,T> createIdentityProcessor(int bufferSize)

This is the main method you must implement in your test incarnation. It must create a Processor, which simply forwards all stream elements from its upstream to its downstream. It must be able to internally buffer the given number of elements.

createHelperPublisher

public abstract org.reactivestreams.spi.Publisher<T> createHelperPublisher(int elements)

Helper method required for running the Publisher rules against a Processor. 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. The stream must not produce the same element twice (in case of an infinite stream this requirement is relaxed to only apply to the elements that are actually requested during all tests).

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.

createPublisher

public org.reactivestreams.spi.Publisher<T> createPublisher(int elements)

mustSupportAPendingElementCountUpToLongMaxValue

public void mustSupportAPendingElementCountUpToLongMaxValue()
                                                     throws java.lang.Exception

Throws:

java.lang.Exception

createPublisher3MustProduceAStreamOfExactly3Elements

public void createPublisher3MustProduceAStreamOfExactly3Elements()
                                                          throws java.lang.Throwable

Throws:

java.lang.Throwable

mustCallOnCompleteOnASubscriberAfterHavingProducedTheFinalStreamElementToIt

public void mustCallOnCompleteOnASubscriberAfterHavingProducedTheFinalStreamElementToIt()
                                                                                 throws java.lang.Throwable

Throws:

java.lang.Throwable

mustStartProducingWithTheOldestStillAvailableElementForASubscriber

public void mustStartProducingWithTheOldestStillAvailableElementForASubscriber()

mustCallOnErrorOnAllItsSubscribersIfItEncountersANonRecoverableError

public void mustCallOnErrorOnAllItsSubscribersIfItEncountersANonRecoverableError()
                                                                          throws java.lang.Exception

Throws:

java.lang.Exception

mustNotCallOnCompleteOrOnErrorMoreThanOncePerSubscriber

public void mustNotCallOnCompleteOrOnErrorMoreThanOncePerSubscriber()

createSubscriber

public org.reactivestreams.spi.Subscriber<T> createSubscriber(org.reactivestreams.tck.SubscriberVerification.SubscriberProbe<T> probe)

mustCancelItsUpstreamSubscriptionIfItsLastDownstreamSubscriptionHasBeenCancelled

public void mustCancelItsUpstreamSubscriptionIfItsLastDownstreamSubscriptionHasBeenCancelled()
                                                                                      throws java.lang.Exception

Throws:

java.lang.Exception

mustImmediatelyPassOnOnErrorEventsReceivedFromItsUpstreamToItsDownstream

public void mustImmediatelyPassOnOnErrorEventsReceivedFromItsUpstreamToItsDownstream()
                                                                              throws java.lang.Exception

Throws:

java.lang.Exception

mustBePreparedToReceiveIncomingElementsFromItsUpstreamEvenIfADownstreamSubscriberHasNotRequestedYet

public void mustBePreparedToReceiveIncomingElementsFromItsUpstreamEvenIfADownstreamSubscriberHasNotRequestedYet()
                                                                                                         throws java.lang.Exception

Throws:

java.lang.Exception

exerciseHappyPath

public void exerciseHappyPath()
                       throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

onSubscribeAndOnNextMustAsynchronouslyScheduleAnEvent

public void onSubscribeAndOnNextMustAsynchronouslyScheduleAnEvent()

onCompleteAndOnErrorMustAsynchronouslyScheduleAnEvent

public void onCompleteAndOnErrorMustAsynchronouslyScheduleAnEvent()

mustNotAcceptAnOnSubscribeEventIfItAlreadyHasAnActiveSubscription

public void mustNotAcceptAnOnSubscribeEventIfItAlreadyHasAnActiveSubscription()
                                                                       throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

mustCallSubscriptionCancelDuringShutdownIfItStillHasAnActiveSubscription

public void mustCallSubscriptionCancelDuringShutdownIfItStillHasAnActiveSubscription()
                                                                              throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

mustEnsureThatAllCallsOnASubscriptionTakePlaceFromTheSameThreadOrProvideExternalSync

public void mustEnsureThatAllCallsOnASubscriptionTakePlaceFromTheSameThreadOrProvideExternalSync()

mustBePreparedToReceiveOneOrMoreOnNextEventsAfterHavingCalledSubscriptionCancel

public void mustBePreparedToReceiveOneOrMoreOnNextEventsAfterHavingCalledSubscriptionCancel()
                                                                                     throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

mustBePreparedToReceiveAnOnCompleteEventWithAPrecedingSubscriptionRequestMore

public void mustBePreparedToReceiveAnOnCompleteEventWithAPrecedingSubscriptionRequestMore()
                                                                                   throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

mustBePreparedToReceiveAnOnCompleteEventWithoutAPrecedingSubscriptionRequestMore

public void mustBePreparedToReceiveAnOnCompleteEventWithoutAPrecedingSubscriptionRequestMore()
                                                                                      throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

mustBePreparedToReceiveAnOnErrorEventWithAPrecedingSubscriptionRequestMore

public void mustBePreparedToReceiveAnOnErrorEventWithAPrecedingSubscriptionRequestMore()
                                                                                throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

mustBePreparedToReceiveAnOnErrorEventWithoutAPrecedingSubscriptionRequestMore

public void mustBePreparedToReceiveAnOnErrorEventWithoutAPrecedingSubscriptionRequestMore()
                                                                                   throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents

public void mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents()

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

mustRequestFromUpstreamForElementsThatHaveBeenRequestedLongAgo

public void mustRequestFromUpstreamForElementsThatHaveBeenRequestedLongAgo()
                                                                    throws java.lang.Exception

Throws:

java.lang.Exception

mustUnblockTheStreamIfABlockingSubscriptionHasBeenCancelled

public void mustUnblockTheStreamIfABlockingSubscriptionHasBeenCancelled()
                                                                 throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException