org.reactivestreams.tck.support

Interface PublisherVerificationRules

All Known Implementing Classes:

IdentityProcessorVerification, PublisherVerification

public interface PublisherVerificationRules

Internal TCK use only. Add / Remove tests for PublisherVerification here to make sure that they arre added/removed in the other places.

Method Summary

Modifier and Type	Method and Description
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	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	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_spec304_requestShouldNotPerformHeavyComputations()
void	untested_spec305_cancelMustNotSynchronouslyPerformHeavyCompuatation()

Method Detail

required_validate_maxElementsFromPublisher

void required_validate_maxElementsFromPublisher()
                                         throws java.lang.Exception

Throws:

java.lang.Exception

required_validate_boundedDepthOfOnNextAndRequestRecursion

void required_validate_boundedDepthOfOnNextAndRequestRecursion()
                                                        throws java.lang.Exception

Throws:

java.lang.Exception

required_createPublisher1MustProduceAStreamOfExactly1Element

void required_createPublisher1MustProduceAStreamOfExactly1Element()
                                                           throws java.lang.Throwable

Throws:

java.lang.Throwable

required_createPublisher3MustProduceAStreamOfExactly3Elements

void required_createPublisher3MustProduceAStreamOfExactly3Elements()
                                                            throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec101_subscriptionRequestMustResultInTheCorrectNumberOfProducedElements

void required_spec101_subscriptionRequestMustResultInTheCorrectNumberOfProducedElements()
                                                                                 throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec102_maySignalLessThanRequestedAndTerminateSubscription

void required_spec102_maySignalLessThanRequestedAndTerminateSubscription()
                                                                  throws java.lang.Throwable

Throws:

java.lang.Throwable

stochastic_spec103_mustSignalOnMethodsSequentially

void stochastic_spec103_mustSignalOnMethodsSequentially()
                                                 throws java.lang.Throwable

Throws:

java.lang.Throwable

optional_spec104_mustSignalOnErrorWhenFails

void optional_spec104_mustSignalOnErrorWhenFails()
                                          throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec105_mustSignalOnCompleteWhenFiniteStreamTerminates

void required_spec105_mustSignalOnCompleteWhenFiniteStreamTerminates()
                                                              throws java.lang.Throwable

Throws:

java.lang.Throwable

optional_spec105_emptyStreamMustTerminateBySignallingOnComplete

void optional_spec105_emptyStreamMustTerminateBySignallingOnComplete()
                                                              throws java.lang.Throwable

Throws:

java.lang.Throwable

untested_spec106_mustConsiderSubscriptionCancelledAfterOnErrorOrOnCompleteHasBeenCalled

void untested_spec106_mustConsiderSubscriptionCancelledAfterOnErrorOrOnCompleteHasBeenCalled()
                                                                                      throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec107_mustNotEmitFurtherSignalsOnceOnCompleteHasBeenSignalled

void required_spec107_mustNotEmitFurtherSignalsOnceOnCompleteHasBeenSignalled()
                                                                       throws java.lang.Throwable

Throws:

java.lang.Throwable

untested_spec107_mustNotEmitFurtherSignalsOnceOnErrorHasBeenSignalled

void untested_spec107_mustNotEmitFurtherSignalsOnceOnErrorHasBeenSignalled()
                                                                    throws java.lang.Throwable

Throws:

java.lang.Throwable

untested_spec108_possiblyCanceledSubscriptionShouldNotReceiveOnErrorOrOnCompleteSignals

void untested_spec108_possiblyCanceledSubscriptionShouldNotReceiveOnErrorOrOnCompleteSignals()
                                                                                      throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec109_mustIssueOnSubscribeForNonNullSubscriber

void required_spec109_mustIssueOnSubscribeForNonNullSubscriber()
                                                        throws java.lang.Throwable

Throws:

java.lang.Throwable

untested_spec109_subscribeShouldNotThrowNonFatalThrowable

void untested_spec109_subscribeShouldNotThrowNonFatalThrowable()
                                                        throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec109_subscribeThrowNPEOnNullSubscriber

void required_spec109_subscribeThrowNPEOnNullSubscriber()
                                                 throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec109_mayRejectCallsToSubscribeIfPublisherIsUnableOrUnwillingToServeThemRejectionMustTriggerOnErrorAfterOnSubscribe

void required_spec109_mayRejectCallsToSubscribeIfPublisherIsUnableOrUnwillingToServeThemRejectionMustTriggerOnErrorAfterOnSubscribe()
                                                                                                                             throws java.lang.Throwable

Throws:

java.lang.Throwable

untested_spec110_rejectASubscriptionRequestIfTheSameSubscriberSubscribesTwice

void untested_spec110_rejectASubscriptionRequestIfTheSameSubscriberSubscribesTwice()
                                                                            throws java.lang.Throwable

Throws:

java.lang.Throwable

optional_spec111_maySupportMultiSubscribe

void optional_spec111_maySupportMultiSubscribe()
                                        throws java.lang.Throwable

Throws:

java.lang.Throwable

optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingOneByOne

void optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingOneByOne()
                                                                                                                throws java.lang.Throwable

Throws:

java.lang.Throwable

optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfront

void optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfront()
                                                                                                                   throws java.lang.Throwable

Throws:

java.lang.Throwable

optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfrontAndCompleteAsExpected

void optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfrontAndCompleteAsExpected()
                                                                                                                                        throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec302_mustAllowSynchronousRequestCallsFromOnNextAndOnSubscribe

void required_spec302_mustAllowSynchronousRequestCallsFromOnNextAndOnSubscribe()
                                                                        throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec303_mustNotAllowUnboundedRecursion

void required_spec303_mustNotAllowUnboundedRecursion()
                                              throws java.lang.Throwable

Throws:

java.lang.Throwable

untested_spec304_requestShouldNotPerformHeavyComputations

void untested_spec304_requestShouldNotPerformHeavyComputations()
                                                        throws java.lang.Exception

Throws:

java.lang.Exception

untested_spec305_cancelMustNotSynchronouslyPerformHeavyCompuatation

void untested_spec305_cancelMustNotSynchronouslyPerformHeavyCompuatation()
                                                                  throws java.lang.Exception

Throws:

java.lang.Exception

required_spec306_afterSubscriptionIsCancelledRequestMustBeNops

void required_spec306_afterSubscriptionIsCancelledRequestMustBeNops()
                                                             throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec307_afterSubscriptionIsCancelledAdditionalCancelationsMustBeNops

void required_spec307_afterSubscriptionIsCancelledAdditionalCancelationsMustBeNops()
                                                                            throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec309_requestZeroMustSignalIllegalArgumentException

void required_spec309_requestZeroMustSignalIllegalArgumentException()
                                                             throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec309_requestNegativeNumberMustSignalIllegalArgumentException

void required_spec309_requestNegativeNumberMustSignalIllegalArgumentException()
                                                                       throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec312_cancelMustMakeThePublisherToEventuallyStopSignaling

void required_spec312_cancelMustMakeThePublisherToEventuallyStopSignaling()
                                                                   throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec313_cancelMustMakeThePublisherEventuallyDropAllReferencesToTheSubscriber

void required_spec313_cancelMustMakeThePublisherEventuallyDropAllReferencesToTheSubscriber()
                                                                                    throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec317_mustSupportAPendingElementCountUpToLongMaxValue

void required_spec317_mustSupportAPendingElementCountUpToLongMaxValue()
                                                               throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec317_mustSupportACumulativePendingElementCountUpToLongMaxValue

void required_spec317_mustSupportACumulativePendingElementCountUpToLongMaxValue()
                                                                         throws java.lang.Throwable

Throws:

java.lang.Throwable

required_spec317_mustNotSignalOnErrorWhenPendingAboveLongMaxValue

void required_spec317_mustNotSignalOnErrorWhenPendingAboveLongMaxValue()
                                                                throws java.lang.Throwable

Throws:

java.lang.Throwable