- registerOnComplete() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe
-
- registerOnComplete() - Method in interface org.reactivestreams.tck.SubscriberWhiteboxVerification.SubscriberProbe
-
Must be called by the test subscriber when it has received an `onComplete` event.
- registerOnError(Throwable) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe
-
- registerOnError(Throwable) - Method in interface org.reactivestreams.tck.SubscriberWhiteboxVerification.SubscriberProbe
-
Must be called by the test subscriber when it has received an `onError` event.
- registerOnNext(T) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe
-
- registerOnNext(T) - Method in interface org.reactivestreams.tck.SubscriberWhiteboxVerification.SubscriberProbe
-
Must be called by the test subscriber when it has received an`onNext` event.
- registerOnSubscribe(SubscriberWhiteboxVerification.SubscriberPuppet) - Method in interface org.reactivestreams.tck.SubscriberWhiteboxVerification.SubscriberPuppeteer
-
Must be called by the test subscriber when it has successfully registered a subscription
inside the `onSubscribe` method.
- registerOnSubscribe(SubscriberWhiteboxVerification.SubscriberPuppet) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxSubscriberProbe
-
- reOpen() - Method in class org.reactivestreams.tck.TestEnvironment.Latch
-
- request(long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber
-
- requestEndOfStream() - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber
-
- requestEndOfStream(long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber
-
- requestEndOfStream(String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber
-
- requestEndOfStream(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber
-
- requestNextElement() - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber
-
- requestNextElement(long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber
-
- requestNextElement(String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber
-
- requestNextElement(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber
-
- requestNextElementOrEndOfStream() - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber
-
- requestNextElementOrEndOfStream(String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber
-
- requestNextElementOrEndOfStream(long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber
-
- requestNextElementOrEndOfStream(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber
-
- requestNextElements(long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber
-
- requestNextElements(long, long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber
-
- requestNextElements(long, long, String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber
-
- requests - Variable in class org.reactivestreams.tck.TestEnvironment.ManualPublisher
-
- required_createPublisher1MustProduceAStreamOfExactly1Element() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_createPublisher1MustProduceAStreamOfExactly1Element() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_createPublisher1MustProduceAStreamOfExactly1Element() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
- required_createPublisher3MustProduceAStreamOfExactly3Elements() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_createPublisher3MustProduceAStreamOfExactly3Elements() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_createPublisher3MustProduceAStreamOfExactly3Elements() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
- required_exerciseWhiteboxHappyPath() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_exerciseWhiteboxHappyPath() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- required_exerciseWhiteboxHappyPath() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- required_mustRequestFromUpstreamForElementsThatHaveBeenRequestedLongAgo() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec101_subscriptionRequestMustResultInTheCorrectNumberOfProducedElements() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec101_subscriptionRequestMustResultInTheCorrectNumberOfProducedElements() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec101_subscriptionRequestMustResultInTheCorrectNumberOfProducedElements() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Asks for a Publisher
that responds to a request pattern of 0 (not requesting upfront), 1, 1 and 2
in a timely manner.
- required_spec102_maySignalLessThanRequestedAndTerminateSubscription() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec102_maySignalLessThanRequestedAndTerminateSubscription() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec102_maySignalLessThanRequestedAndTerminateSubscription() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Asks for a short Publisher
and verifies that requesting once and with more than the length (but bounded) results in the
correct number of items to be emitted (i.e., length 3 and request 10) followed by an onComplete
signal.
- required_spec104_mustCallOnErrorOnAllItsSubscribersIfItEncountersANonRecoverableError() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec105_mustSignalOnCompleteWhenFiniteStreamTerminates() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec105_mustSignalOnCompleteWhenFiniteStreamTerminates() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec105_mustSignalOnCompleteWhenFiniteStreamTerminates() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Asks for a short Publisher
(i.e., length 3) and verifies, after requesting one by one, the sequence
completes normally.
- required_spec107_mustNotEmitFurtherSignalsOnceOnCompleteHasBeenSignalled() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec107_mustNotEmitFurtherSignalsOnceOnCompleteHasBeenSignalled() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec107_mustNotEmitFurtherSignalsOnceOnCompleteHasBeenSignalled() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Asks for a single-element Publisher
and checks if requesting after the terminal event doesn't
lead to more items or terminal signals to be emitted.
- required_spec109_mayRejectCallsToSubscribeIfPublisherIsUnableOrUnwillingToServeThemRejectionMustTriggerOnErrorAfterOnSubscribe() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec109_mayRejectCallsToSubscribeIfPublisherIsUnableOrUnwillingToServeThemRejectionMustTriggerOnErrorAfterOnSubscribe() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec109_mayRejectCallsToSubscribeIfPublisherIsUnableOrUnwillingToServeThemRejectionMustTriggerOnErrorAfterOnSubscribe() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Asks for an error Publisher
that should call onSubscribe
exactly once
followed by a single call to onError()
without receiving any requests.
- required_spec109_mustIssueOnSubscribeForNonNullSubscriber() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec109_mustIssueOnSubscribeForNonNullSubscriber() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec109_mustIssueOnSubscribeForNonNullSubscriber() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Asks for an empty Publisher
and verifies if onSubscribe
signal was emitted before
any other onNext
, onError
or onComplete
signal.
- required_spec109_subscribeThrowNPEOnNullSubscriber() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec109_subscribeThrowNPEOnNullSubscriber() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec109_subscribeThrowNPEOnNullSubscriber() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Asks for an empty Publisher
and calls subscribe
on it with null
that should result in
a NullPointerException
to be thrown.
- required_spec201_blackbox_mustSignalDemandViaSubscriptionRequest() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- required_spec201_blackbox_mustSignalDemandViaSubscriptionRequest() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Asks for a Subscriber
instance, expects it to call request()
in
a timely manner and signals as many onNext
items as the very first request
amount specified by the Subscriber
.
- required_spec201_mustSignalDemandViaSubscriptionRequest() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec201_mustSignalDemandViaSubscriptionRequest() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- required_spec201_mustSignalDemandViaSubscriptionRequest() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- required_spec203_blackbox_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- required_spec203_blackbox_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Asks for a Subscriber
, signals an onSubscribe
followed by an onComplete
synchronously,
and checks if neither request
nor cancel
was called from within the Subscriber
's
onComplete
implementation.
- required_spec203_blackbox_mustNotCallMethodsOnSubscriptionOrPublisherInOnError() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- required_spec203_blackbox_mustNotCallMethodsOnSubscriptionOrPublisherInOnError() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Asks for a Subscriber
, signals an onSubscribe
followed by an onError
synchronously,
and checks if neither request
nor cancel
was called from within the Subscriber
's
onComplete
implementation.
- required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnError() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnError() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnError() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- required_spec205_blackbox_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- required_spec205_blackbox_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Asks for a Subscriber
, signals onSubscribe
twice synchronously and expects the second Subscription
gets
cancelled in a timely manner and without any calls to its request
method.
- required_spec205_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec205_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- required_spec205_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- required_spec208_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec208_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- required_spec208_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Asks for a Subscriber
and expects it to handle onComplete
independent of whether the Subscriber
requests items or not.
- required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Asks for a Subscriber
, expects it to request some amount and in turn be able to receive an onComplete
synchronously from the request
call without any onNext
signals before that.
- required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- required_spec210_blackbox_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- required_spec210_blackbox_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Asks for a Subscriber
, signals onSubscribe
followed by an onError
synchronously.
- required_spec210_blackbox_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- required_spec210_blackbox_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Asks for a Subscriber
, signals onSubscribe
followed by an onError
synchronously.
- required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- required_spec213_blackbox_onError_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- required_spec213_blackbox_onError_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Asks for a Subscriber
, signals an onSubscribe
event followed by a
onError
with null
as a parameter and
expects an immediate NullPointerException
to be thrown by the Subscriber.onError
method.
- required_spec213_blackbox_onNext_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- required_spec213_blackbox_onNext_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Asks for a Subscriber
, signals an onSubscribe
event followed by a
onNext
with null
as a parameter and
expects an immediate NullPointerException
to be thrown by the Subscriber.onNext
method.
- required_spec213_blackbox_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- required_spec213_blackbox_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Asks for a Subscriber
and signals an onSubscribe
event with null
as a parameter and
expects an immediate NullPointerException
to be thrown by the Subscriber.onSubscribe
method.
- required_spec213_onError_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec213_onError_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- required_spec213_onError_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- required_spec213_onNext_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec213_onNext_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- required_spec213_onNext_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- required_spec213_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec213_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- required_spec213_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- required_spec302_mustAllowSynchronousRequestCallsFromOnNextAndOnSubscribe() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec302_mustAllowSynchronousRequestCallsFromOnNextAndOnSubscribe() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec302_mustAllowSynchronousRequestCallsFromOnNextAndOnSubscribe() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Asks for a short Publisher
(length 6), requests several times from within onSubscribe
and then requests
one-by-one from onNext
.
- required_spec303_mustNotAllowUnboundedRecursion() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec303_mustNotAllowUnboundedRecursion() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec303_mustNotAllowUnboundedRecursion() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
- required_spec306_afterSubscriptionIsCancelledRequestMustBeNops() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec306_afterSubscriptionIsCancelledRequestMustBeNops() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec306_afterSubscriptionIsCancelledRequestMustBeNops() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Asks for a short Publisher
(length 3) and verifies that cancelling without requesting anything, then requesting
items should result in no signals to be emitted.
- required_spec307_afterSubscriptionIsCancelledAdditionalCancelationsMustBeNops() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec307_afterSubscriptionIsCancelledAdditionalCancelationsMustBeNops() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec307_afterSubscriptionIsCancelledAdditionalCancelationsMustBeNops() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Asks for a single-element Publisher
and verifies that without requesting anything, cancelling the sequence
multiple times should result in no signals to be emitted and should result in an thrown exception.
- required_spec308_requestMustRegisterGivenNumberElementsToBeProduced() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec308_requestMustRegisterGivenNumberElementsToBeProduced() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- required_spec308_requestMustRegisterGivenNumberElementsToBeProduced() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- required_spec309_requestNegativeNumberMustSignalIllegalArgumentException() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec309_requestNegativeNumberMustSignalIllegalArgumentException() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec309_requestNegativeNumberMustSignalIllegalArgumentException() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Asks for a short Publisher
(length 10) and issues a random, negative request()
call which should
trigger an onError
call with an IllegalArgumentException
.
- required_spec309_requestZeroMustSignalIllegalArgumentException() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec309_requestZeroMustSignalIllegalArgumentException() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec309_requestZeroMustSignalIllegalArgumentException() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Asks for a short Publisher
(length 10) and issues a request(0)
which should trigger an onError
call
with an IllegalArgumentException
.
- required_spec312_cancelMustMakeThePublisherToEventuallyStopSignaling() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec312_cancelMustMakeThePublisherToEventuallyStopSignaling() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec312_cancelMustMakeThePublisherToEventuallyStopSignaling() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Asks for a short Publisher
(length 20), requests some items (less than the length), consumes one item then
cancels the sequence and verifies the publisher emitted at most the requested amount and stopped emitting (or terminated).
- required_spec313_cancelMustMakeThePublisherEventuallyDropAllReferencesToTheSubscriber() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec313_cancelMustMakeThePublisherEventuallyDropAllReferencesToTheSubscriber() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec313_cancelMustMakeThePublisherEventuallyDropAllReferencesToTheSubscriber() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Asks for a short Publisher
(length 3) requests and consumes one element from it, cancels the Subscription
, calls System.gc()
and then checks if all references to the test Subscriber
has been dropped (by checking
the WeakReference
has been emptied).
- required_spec317_mustNotSignalOnErrorWhenPendingAboveLongMaxValue() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec317_mustNotSignalOnErrorWhenPendingAboveLongMaxValue() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec317_mustNotSignalOnErrorWhenPendingAboveLongMaxValue() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Asks for a very long Publisher
(up to Integer.MAX_VALUE
), requests Long.MAX_VALUE - 1
after
each received item and expects no failure due to a potential overflow in the pending emission count while consuming
10 items and cancelling the sequence.
- required_spec317_mustSupportACumulativePendingElementCountUpToLongMaxValue() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec317_mustSupportACumulativePendingElementCountUpToLongMaxValue() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec317_mustSupportACumulativePendingElementCountUpToLongMaxValue() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Asks for a short Publisher
(length 3) and requests Long.MAX_VALUE
from it in total (split across
two Long.MAX_VALUE / 2
and one request(1)
), verifying that the
Publisher
emits all of its items and completes normally.
- required_spec317_mustSupportAPendingElementCountUpToLongMaxValue() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_spec317_mustSupportAPendingElementCountUpToLongMaxValue() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_spec317_mustSupportAPendingElementCountUpToLongMaxValue() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Asks for a short Publisher
(length 3) and requests Long.MAX_VALUE
from it, verifying that the
Publisher
emits all of its items and completes normally
and does not keep spinning attempting to fulfill the Long.MAX_VALUE
demand by some means.
- required_validate_boundedDepthOfOnNextAndRequestRecursion() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_validate_boundedDepthOfOnNextAndRequestRecursion() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_validate_boundedDepthOfOnNextAndRequestRecursion() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
- required_validate_maxElementsFromPublisher() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- required_validate_maxElementsFromPublisher() - Method in class org.reactivestreams.tck.PublisherVerification
-
- required_validate_maxElementsFromPublisher() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
- run(Publisher<T>) - Method in interface org.reactivestreams.tck.PublisherVerification.PublisherTestRun
-
- untested_spec106_mustConsiderSubscriptionCancelledAfterOnErrorOrOnCompleteHasBeenCalled() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec106_mustConsiderSubscriptionCancelledAfterOnErrorOrOnCompleteHasBeenCalled() - Method in class org.reactivestreams.tck.PublisherVerification
-
- untested_spec106_mustConsiderSubscriptionCancelledAfterOnErrorOrOnCompleteHasBeenCalled() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Currently, this test is skipped because it is unclear this rule can be effectively checked
on a Publisher
instance without looking into or hooking into the implementation of it.
- untested_spec107_mustNotEmitFurtherSignalsOnceOnErrorHasBeenSignalled() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec107_mustNotEmitFurtherSignalsOnceOnErrorHasBeenSignalled() - Method in class org.reactivestreams.tck.PublisherVerification
-
- untested_spec107_mustNotEmitFurtherSignalsOnceOnErrorHasBeenSignalled() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
- untested_spec108_possiblyCanceledSubscriptionShouldNotReceiveOnErrorOrOnCompleteSignals() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec108_possiblyCanceledSubscriptionShouldNotReceiveOnErrorOrOnCompleteSignals() - Method in class org.reactivestreams.tck.PublisherVerification
-
- untested_spec108_possiblyCanceledSubscriptionShouldNotReceiveOnErrorOrOnCompleteSignals() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Currently, this test is skipped because there was no agreement on how to verify its "eventually" requirement.
- untested_spec109_subscribeShouldNotThrowNonFatalThrowable() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec109_subscribeShouldNotThrowNonFatalThrowable() - Method in class org.reactivestreams.tck.PublisherVerification
-
- untested_spec109_subscribeShouldNotThrowNonFatalThrowable() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Currently, this test is skipped because there is no common agreement on what is to be considered a fatal exception and
besides, Publisher.subscribe
is only allowed throw a NullPointerException
and any other
exception would require looking into or hooking into the implementation of the Publisher
.
- untested_spec110_rejectASubscriptionRequestIfTheSameSubscriberSubscribesTwice() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec110_rejectASubscriptionRequestIfTheSameSubscriberSubscribesTwice() - Method in class org.reactivestreams.tck.PublisherVerification
-
- untested_spec110_rejectASubscriptionRequestIfTheSameSubscriberSubscribesTwice() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Currently, this test is skipped because enforcing rule §1.10 requires unlimited retention and reference-equal checks on
all incoming Subscriber
which is generally infeasible, plus reusing the same Subscriber
instance is
better detected (or ignored) inside Subscriber.onSubscribe
when the method is called multiple times.
- untested_spec202_blackbox_shouldAsynchronouslyDispatch() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- untested_spec202_blackbox_shouldAsynchronouslyDispatch() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Currently, this test is skipped because there is no agreed upon approach how
to detect if the Subscriber
really goes async or just responds in
a timely manner.
- untested_spec202_shouldAsynchronouslyDispatch() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec202_shouldAsynchronouslyDispatch() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- untested_spec202_shouldAsynchronouslyDispatch() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- untested_spec204_blackbox_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- untested_spec204_blackbox_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Currently, this test is skipped because there is no way to check what the Subscriber
"considers"
since rule §2.3 forbids interaction from within the onError
and onComplete
methods.
- untested_spec204_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec204_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- untested_spec204_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- untested_spec206_blackbox_mustCallSubscriptionCancelIfItIsNoLongerValid() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- untested_spec206_blackbox_mustCallSubscriptionCancelIfItIsNoLongerValid() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Currently, this test is skipped because it requires more control over the Subscriber
implementation
to make it cancel the Subscription
for some external condition.
- untested_spec206_mustCallSubscriptionCancelIfItIsNoLongerValid() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec206_mustCallSubscriptionCancelIfItIsNoLongerValid() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- untested_spec206_mustCallSubscriptionCancelIfItIsNoLongerValid() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- untested_spec207_blackbox_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- untested_spec207_blackbox_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Currently, this test is skipped because it requires more control over the Subscriber
implementation
to issue requests based on external stimulus.
- untested_spec207_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec207_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- untested_spec207_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- untested_spec208_blackbox_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- untested_spec208_blackbox_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Currently, this test is skipped because there is no way to make the Subscriber
implementation
cancel the test's Subscription
and check the outcome of sending onNext
s after such
cancel.
- untested_spec211_blackbox_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- untested_spec211_blackbox_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Currently, this test is skipped because it would require analyzing what the Subscriber
implementation
does.
- untested_spec211_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec211_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- untested_spec211_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- untested_spec212_blackbox_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- untested_spec212_blackbox_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Currently, this test is skipped because the test for
§2.5
is in a better position to test for handling the reuse of the same
Subscriber
.
- untested_spec212_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality_specViolation() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec212_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality_specViolation() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- untested_spec212_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality_specViolation() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- untested_spec213_blackbox_failingOnSignalInvocation() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- untested_spec213_blackbox_failingOnSignalInvocation() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Currently, this test is skipped because it would require more control over the Subscriber
to
fail internally in response to a set of legal event emissions, not throw any exception from the Subscriber
methods and have it cancel the Subscription
.
- untested_spec213_failingOnSignalInvocation() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec213_failingOnSignalInvocation() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- untested_spec213_failingOnSignalInvocation() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- untested_spec301_blackbox_mustNotBeCalledOutsideSubscriberContext() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- untested_spec301_blackbox_mustNotBeCalledOutsideSubscriberContext() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Currently, this test is skipped because there is no agreed upon way for specifying, enforcing and testing
a Subscriber
with an arbitrary context.
- untested_spec301_mustNotBeCalledOutsideSubscriberContext() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec301_mustNotBeCalledOutsideSubscriberContext() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- untested_spec301_mustNotBeCalledOutsideSubscriberContext() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- untested_spec304_requestShouldNotPerformHeavyComputations() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec304_requestShouldNotPerformHeavyComputations() - Method in class org.reactivestreams.tck.PublisherVerification
-
- untested_spec304_requestShouldNotPerformHeavyComputations() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Currently, this test is skipped because a request
could enter into a synchronous computation via onNext
legally and otherwise there is no common agreement how to detect such heavy computation reliably.
- untested_spec305_cancelMustNotSynchronouslyPerformHeavyComputation() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec305_cancelMustNotSynchronouslyPerformHeavyComputation() - Method in class org.reactivestreams.tck.PublisherVerification
-
- untested_spec305_cancelMustNotSynchronouslyPerformHeavyComputation() - Method in interface org.reactivestreams.tck.support.PublisherVerificationRules
-
Currently, this test is skipped because there is no reliable agreed upon way to detect a heavy computation.
- untested_spec308_blackbox_requestMustRegisterGivenNumberElementsToBeProduced() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- untested_spec308_blackbox_requestMustRegisterGivenNumberElementsToBeProduced() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Currently, this test is skipped because element production is the responsibility of the Publisher
and
a Subscription
is not expected to be the active element in an established subscription.
- untested_spec310_blackbox_requestMaySynchronouslyCallOnNextOnSubscriber() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- untested_spec310_blackbox_requestMaySynchronouslyCallOnNextOnSubscriber() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Currently, this test is skipped because element production is the responsibility of the Publisher
and
a Subscription
is not expected to be the active element in an established subscription.
- untested_spec310_requestMaySynchronouslyCallOnNextOnSubscriber() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec310_requestMaySynchronouslyCallOnNextOnSubscriber() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- untested_spec310_requestMaySynchronouslyCallOnNextOnSubscriber() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- untested_spec311_blackbox_requestMaySynchronouslyCallOnCompleteOrOnError() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- untested_spec311_blackbox_requestMaySynchronouslyCallOnCompleteOrOnError() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Currently, this test is skipped because signal production is the responsibility of the Publisher
and
a Subscription
is not expected to be the active element in an established subscription.
- untested_spec311_requestMaySynchronouslyCallOnCompleteOrOnError() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec311_requestMaySynchronouslyCallOnCompleteOrOnError() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- untested_spec311_requestMaySynchronouslyCallOnCompleteOrOnError() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- untested_spec314_blackbox_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- untested_spec314_blackbox_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Currently, this test is skipped because it is the responsibility of the Publisher
deal with the case
that all subscribers have cancelled their subscription.
- untested_spec314_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec314_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- untested_spec314_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- untested_spec315_blackbox_cancelMustNotThrowExceptionAndMustSignalOnError() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- untested_spec315_blackbox_cancelMustNotThrowExceptionAndMustSignalOnError() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Currently, this test is skipped because it requires more control over the Subscriber
implementation
thus there is no way to detect that the Subscriber
called its own onError
method in response
to an exception thrown from Subscription.cancel
.
- untested_spec315_cancelMustNotThrowExceptionAndMustSignalOnError() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec315_cancelMustNotThrowExceptionAndMustSignalOnError() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- untested_spec315_cancelMustNotThrowExceptionAndMustSignalOnError() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-
- untested_spec316_blackbox_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification
-
- untested_spec316_blackbox_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber() - Method in interface org.reactivestreams.tck.support.SubscriberBlackboxVerificationRules
-
Currently, this test is skipped because it requires more control over the Subscriber
implementation
thus there is no way to detect that the Subscriber
called its own onError
method in response
to an exception thrown from Subscription.request
.
- untested_spec316_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber() - Method in class org.reactivestreams.tck.IdentityProcessorVerification
-
- untested_spec316_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification
-
- untested_spec316_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber() - Method in interface org.reactivestreams.tck.support.SubscriberWhiteboxVerificationRules
-