A C D E F G I M N O P S T V

A

activePublisherTest(int, PublisherVerification.PublisherTestRun<T>) - Method in class org.reactivestreams.tck.PublisherVerification

apply(Throwable) - Static method in class org.reactivestreams.tck.support.NonFatal

Returns true if the provided `Throwable` is to be considered non-fatal, or false if it is to be considered fatal

C

completedPublisherTest(PublisherVerification.PublisherTestRun<T>) - Method in class org.reactivestreams.tck.PublisherVerification

createCompletedStatePublisher() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

createCompletedStatePublisher() - Method in class org.reactivestreams.tck.PublisherVerification

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

createErrorStatePublisher() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

createErrorStatePublisher() - Method in class org.reactivestreams.tck.PublisherVerification

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

createHelperPublisher(int) - Method in class org.reactivestreams.tck.IdentityProcessorVerification

Helper method required for running the Publisher rules against a Processor.

createIdentityProcessor(int) - Method in class org.reactivestreams.tck.IdentityProcessorVerification

This is the main method you must implement in your test incarnation.

createPublisher(int) - Method in class org.reactivestreams.tck.IdentityProcessorVerification

createPublisher(int) - Method in class org.reactivestreams.tck.PublisherVerification

This is the main method you must implement in your test incarnation.

createPublisher3MustProduceAStreamOfExactly3Elements() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

createPublisher3MustProduceAStreamOfExactly3Elements() - Method in class org.reactivestreams.tck.PublisherVerification

createSubscriber(SubscriberVerification.SubscriberProbe<T>) - Method in class org.reactivestreams.tck.IdentityProcessorVerification

D

defaultTimeoutMillis() - Method in class org.reactivestreams.tck.TestEnvironment

E

empty() - Static method in class org.reactivestreams.tck.support.Optional

errorPublisherTest(PublisherVerification.PublisherTestRun<T>) - Method in class org.reactivestreams.tck.PublisherVerification

exerciseHappyPath() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

expectThrowingOf(Class<T>, String, Runnable) - Method in class org.reactivestreams.tck.TestEnvironment

F

flop(String) - Method in class org.reactivestreams.tck.TestEnvironment

G

get() - Method in class org.reactivestreams.tck.support.Optional

I

IdentityProcessorVerification<T> - Class in org.reactivestreams.tck

IdentityProcessorVerification(TestEnvironment, long) - Constructor for class org.reactivestreams.tck.IdentityProcessorVerification

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, long, int) - Constructor for class org.reactivestreams.tck.IdentityProcessorVerification

isDefined() - Method in class org.reactivestreams.tck.support.Optional

isEmpty() - Method in class org.reactivestreams.tck.support.Optional

M

mustBePreparedToReceiveAnOnCompleteEventWithAPrecedingSubscriptionRequestMore() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustBePreparedToReceiveAnOnCompleteEventWithoutAPrecedingSubscriptionRequestMore() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustBePreparedToReceiveAnOnErrorEventWithAPrecedingSubscriptionRequestMore() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustBePreparedToReceiveAnOnErrorEventWithoutAPrecedingSubscriptionRequestMore() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustBePreparedToReceiveIncomingElementsFromItsUpstreamEvenIfADownstreamSubscriberHasNotRequestedYet() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustBePreparedToReceiveOneOrMoreOnNextEventsAfterHavingCalledSubscriptionCancel() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustCallOnCompleteOnASubscriberAfterHavingProducedTheFinalStreamElementToIt() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustCallOnCompleteOnASubscriberAfterHavingProducedTheFinalStreamElementToIt() - Method in class org.reactivestreams.tck.PublisherVerification

mustCallOnErrorOnAllItsSubscribersIfItEncountersANonRecoverableError() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustCallOnErrorOnAllItsSubscribersIfItEncountersANonRecoverableError() - Method in class org.reactivestreams.tck.PublisherVerification

mustCallSubscriptionCancelDuringShutdownIfItStillHasAnActiveSubscription() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustCancelItsUpstreamSubscriptionIfItsLastDownstreamSubscriptionHasBeenCancelled() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustEnsureThatAllCallsOnASubscriptionTakePlaceFromTheSameThreadOrProvideExternalSync() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustImmediatelyPassOnOnErrorEventsReceivedFromItsUpstreamToItsDownstream() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustNotAcceptAnOnSubscribeEventIfItAlreadyHasAnActiveSubscription() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustNotCallOnCompleteOrOnErrorMoreThanOncePerSubscriber() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustNotCallOnCompleteOrOnErrorMoreThanOncePerSubscriber() - Method in class org.reactivestreams.tck.PublisherVerification

mustNotCallOnNextAfterHavingIssuedAnOnCompleteOrOnErrorCallOnASubscriber() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustNotCallOnNextAfterHavingIssuedAnOnCompleteOrOnErrorCallOnASubscriber() - Method in class org.reactivestreams.tck.PublisherVerification

mustProduceTheSameElementsInTheSameSequenceForAllItsSubscribers() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustProduceTheSameElementsInTheSameSequenceForAllItsSubscribers() - Method in class org.reactivestreams.tck.PublisherVerification

mustRequestFromUpstreamForElementsThatHaveBeenRequestedLongAgo() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustStartProducingWithTheOldestStillAvailableElementForASubscriber() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustStartProducingWithTheOldestStillAvailableElementForASubscriber() - Method in class org.reactivestreams.tck.PublisherVerification

mustSupportAPendingElementCountUpToLongMaxValue() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

mustSupportAPendingElementCountUpToLongMaxValue() - Method in class org.reactivestreams.tck.PublisherVerification

mustUnblockTheStreamIfABlockingSubscriptionHasBeenCancelled() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

N

newManualSubscriber(Publisher<T>) - Method in class org.reactivestreams.tck.TestEnvironment

newManualSubscriber(Publisher<T>, long) - Method in class org.reactivestreams.tck.TestEnvironment

NonFatal - Class in org.reactivestreams.tck.support

Copy of scala.control.util.NonFatal in order to not depend on scala-library

NonFatal() - Constructor for class org.reactivestreams.tck.support.NonFatal

O

of(T) - Static method in class org.reactivestreams.tck.support.Optional

onCompleteAndOnErrorMustAsynchronouslyScheduleAnEvent() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

onSubscribeAndOnNextMustAsynchronouslyScheduleAnEvent() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

onSubscriptionCancelThePublisherMustEventuallyCeaseToCallAnyMethodsOnTheSubscriber() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

onSubscriptionCancelThePublisherMustEventuallyCeaseToCallAnyMethodsOnTheSubscriber() - Method in class org.reactivestreams.tck.PublisherVerification

onSubscriptionCancelThePublisherMustEventuallyDropAllReferencesToTheSubscriber() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

onSubscriptionCancelThePublisherMustEventuallyDropAllReferencesToTheSubscriber() - Method in class org.reactivestreams.tck.PublisherVerification

Optional<T> - Class in org.reactivestreams.tck.support

Optional() - Constructor for class org.reactivestreams.tck.support.Optional

org.reactivestreams.tck - package org.reactivestreams.tck

org.reactivestreams.tck.support - package org.reactivestreams.tck.support

P

potentiallyPendingTest(Publisher<T>, PublisherVerification.PublisherTestRun<T>) - Method in class org.reactivestreams.tck.PublisherVerification

publisherSubscribeWhenActiveMustCallOnSubscribeFirst() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

publisherSubscribeWhenActiveMustCallOnSubscribeFirst() - Method in class org.reactivestreams.tck.PublisherVerification

publisherSubscribeWhenActiveMustRejectDoubleSubscription() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

publisherSubscribeWhenActiveMustRejectDoubleSubscription() - Method in class org.reactivestreams.tck.PublisherVerification

publisherSubscribeWhenCompletedMustTriggerOnCompleteAndNotOnSubscribe() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

publisherSubscribeWhenCompletedMustTriggerOnCompleteAndNotOnSubscribe() - Method in class org.reactivestreams.tck.PublisherVerification

publisherSubscribeWhenInErrorStateMustTriggerOnErrorAndNotOnSubscribe() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

publisherSubscribeWhenInErrorStateMustTriggerOnErrorAndNotOnSubscribe() - Method in class org.reactivestreams.tck.PublisherVerification

publisherSubscribeWhenInShutDownStateMustTriggerOnErrorAndNotOnSubscribe() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

publisherSubscribeWhenInShutDownStateMustTriggerOnErrorAndNotOnSubscribe() - Method in class org.reactivestreams.tck.PublisherVerification

PublisherVerification<T> - Class in org.reactivestreams.tck

PublisherVerification(TestEnvironment, long) - Constructor for class org.reactivestreams.tck.PublisherVerification

S

subscribe(Publisher<T>, TestEnvironment.TestSubscriber<T>) - Method in class org.reactivestreams.tck.TestEnvironment

subscribe(Publisher<T>, TestEnvironment.TestSubscriber<T>, long) - Method in class org.reactivestreams.tck.TestEnvironment

SubscriberVerification<T> - Class in org.reactivestreams.tck

SubscriberVerification(TestEnvironment) - Constructor for class org.reactivestreams.tck.SubscriberVerification

subscriptionCancelWhenCancelledMustIgnoreCall() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

subscriptionCancelWhenCancelledMustIgnoreCall() - Method in class org.reactivestreams.tck.PublisherVerification

subscriptionRequestMoreMustResultInTheCorrectNumberOfProducedElements() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

subscriptionRequestMoreMustResultInTheCorrectNumberOfProducedElements() - Method in class org.reactivestreams.tck.PublisherVerification

subscriptionRequestMoreMustThrowIfArgumentIsNonPositive() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

subscriptionRequestMoreMustThrowIfArgumentIsNonPositive() - Method in class org.reactivestreams.tck.PublisherVerification

subscriptionRequestMoreWhenCancelledMustIgnoreTheCall() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

subscriptionRequestMoreWhenCancelledMustIgnoreTheCall() - Method in class org.reactivestreams.tck.PublisherVerification

T

TEST_BUFFER_SIZE - Static variable in class org.reactivestreams.tck.TestEnvironment

TestEnvironment - Class in org.reactivestreams.tck

TestEnvironment(long) - Constructor for class org.reactivestreams.tck.TestEnvironment

Tests must specify the timeout for expected outcome of asynchronous interactions.

toString() - Method in class org.reactivestreams.tck.support.Optional

V

verifyNoAsyncErrors() - Method in class org.reactivestreams.tck.TestEnvironment

A C D E F G I M N O P S T V