A B C D E F G H I L M N O P R S T U V W

A

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

Test for feature that SHOULD/MUST be implemented, using a live publisher.

add(T) - Method in class org.reactivestreams.tck.TestEnvironment.Receptacle

apply(In) - Method in interface org.reactivestreams.tck.flow.support.Function

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

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

B

BlackboxProbe(TestEnvironment, TestEnvironment.Promise<Subscriber<? super T>>) - Constructor for class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

BlackboxSubscriberProxy(TestEnvironment, Subscriber<T>) - Constructor for class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxSubscriberProxy

blackboxSubscriberTest(SubscriberBlackboxVerification.BlackboxTestStageTestRun) - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

blackboxSubscriberWithoutSetupTest(SubscriberBlackboxVerification.BlackboxTestStageTestRun) - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

BlackboxTestStage(TestEnvironment) - Constructor for class org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStage

BlackboxTestStage(TestEnvironment, boolean) - Constructor for class org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStage

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

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

In order to verify rule 3.3 of the reactive streams spec, this number will be used to check if a Subscription actually solves the "unbounded recursion" problem by not allowing the number of recursive calls to exceed the number returned by this method.

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

In order to verify rule 3.3 of the reactive streams spec, this number will be used to check if a Subscription actually solves the "unbounded recursion" problem by not allowing the number of recursive calls to exceed the number returned by this method.

C

cancel() - Method in class org.reactivestreams.tck.TestEnvironment.TestSubscriber

cancelled - Variable in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

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

close() - Method in class org.reactivestreams.tck.TestEnvironment.Latch

complete() - Method in class org.reactivestreams.tck.TestEnvironment.Receptacle

complete(T) - Method in class org.reactivestreams.tck.TestEnvironment.Promise

Allows using expectCompletion to await for completion of the value and complete it _then_

completed(TestEnvironment, T) - Static method in class org.reactivestreams.tck.TestEnvironment.Promise

completeImmediatly(T) - Method in class org.reactivestreams.tck.TestEnvironment.Promise

Completes the promise right away, it is not possible to expectCompletion on a Promise completed this way

createBlackboxSubscriberProxy(TestEnvironment, Subscriber<T>) - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStage

createElement(int) - Method in class org.reactivestreams.tck.WithHelperPublisher

Implement this method to match your expected element type.

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

By implementing this method, additional TCK tests concerning a "failed" publishers will be run.

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

By implementing this method, additional TCK tests concerning a "failed" publishers will be run.

createHelperPublisher(long) - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStage

createHelperPublisher(long) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

createHelperPublisher(long) - Method in class org.reactivestreams.tck.WithHelperPublisher

Helper method required for creating the Publisher to which the tested Subscriber will be subscribed and tested against.

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

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

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

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

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

createSubscriber() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

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

createSubscriber(SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T>) - Method in class org.reactivestreams.tck.IdentityProcessorVerification

createSubscriber(SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T>) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

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

createWhiteboxSubscriberProbe(TestEnvironment) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

D

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

If TestEnvironment#printlnDebug is true, print debug message to std out.

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

This timeout is used when asserting that no further signals are emitted.

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

This timeout is used when waiting for a signal to arrive.

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

Override this method and return true if the Processor returned by the IdentityProcessorVerification.createIdentityProcessor(int) coordinates its Subscribers request amounts and only delivers onNext signals if all Subscribers have indicated (via their Subscription#request(long)) they are ready to receive elements.

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

E

elements - Variable in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

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

env - Variable in class org.reactivestreams.tck.SubscriberBlackboxVerification

env - Variable in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

env - Variable in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

env - Variable in class org.reactivestreams.tck.TestEnvironment.TestSubscriber

envDefaultNoSignalsTimeoutMillis() - Static method in class org.reactivestreams.tck.TestEnvironment

Tries to parse the env variable DEFAULT_NO_SIGNALS_TIMEOUT_MILLIS as long and returns the value if present OR its default value.

envDefaultTimeoutMillis() - Static method in class org.reactivestreams.tck.TestEnvironment

Tries to parse the env variable DEFAULT_TIMEOUT_MILLIS as long and returns the value if present OR its default value.

envPublisherReferenceGCTimeoutMillis() - Static method in class org.reactivestreams.tck.PublisherVerification

Tries to parse the env variable PUBLISHER_REFERENCE_GC_TIMEOUT_MILLIS as long and returns the value if present, OR its default value (PublisherVerification.DEFAULT_PUBLISHER_REFERENCE_GC_TIMEOUT_MILLIS).

error - Variable in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

expectCancelling() - Method in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

expectCancelling(long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

expectClose(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.Latch

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

expectCompletion() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

expectCompletion() - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

expectCompletion(long) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

expectCompletion(long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

expectCompletion(long, String) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

expectCompletion(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

expectCompletion(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.Promise

expectCompletion(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.Receptacle

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

expectError(Class<E>) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

expectError(Class<E>) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

expectError(Class<E>, long) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

expectError(Class<E>, long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

expectError(Class<E>, long, String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

expectError(Class<E>, long, String) - Method in class org.reactivestreams.tck.TestEnvironment.Receptacle

expectError(Class<E>, String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

expectError(Throwable) - Method in class org.reactivestreams.tck.IdentityProcessorVerification.ManualSubscriberWithErrorCollection

expectError(Throwable) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

expectError(Throwable, long) - Method in class org.reactivestreams.tck.IdentityProcessorVerification.ManualSubscriberWithErrorCollection

expectError(Throwable, long) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

expectErrorWithMessage(Class<E>, String) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

expectErrorWithMessage(Class<E>, String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

expectErrorWithMessage(Class<E>, String, long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

expectErrorWithMessage(Class<E>, List<String>) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

expectErrorWithMessage(Class<E>, List<String>, long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

expectExactRequest(long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

expectExactRequest(long, long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

expectNext() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

expectNext(T) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

expectNext(T) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

expectNext(T, long) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

expectNext(T, long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

expectNextElement(TestEnvironment.ManualSubscriber<T>, T) - Method in class org.reactivestreams.tck.IdentityProcessorVerification.TestSetup

expectNextElement(TestEnvironment.ManualSubscriber<T>, T, String) - Method in class org.reactivestreams.tck.IdentityProcessorVerification.TestSetup

expectNone() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

expectNone() - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

expectNone(long) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

expectNone(long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

expectNone(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

expectNone(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.Receptacle

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

expectNoRequest() - Method in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

expectNoRequest(long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

expectRequest() - Method in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

expectRequest(long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

expectRequest(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

F

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

Looks for given method method in stack trace.

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

To flop means to "fail asynchronously", either by onErroring or by failing some TCK check triggered asynchronously.

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

To flop means to "fail asynchronously", either by onErroring or by failing some TCK check triggered asynchronously.

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

To flop means to "fail asynchronously", either by onErroring or by failing some TCK check triggered asynchronously.

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

To flop means to "fail asynchronously", either by onErroring or by failing some TCK check triggered asynchronously.

Function<In,Out> - Interface in org.reactivestreams.tck.flow.support

G

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

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

H

HelperPublisher<T> - Class in org.reactivestreams.tck.flow.support

HelperPublisher(int, int, Function<Integer, T>, Executor) - Constructor for class org.reactivestreams.tck.flow.support.HelperPublisher

I

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

IdentityProcessorVerification(TestEnvironment) - 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) - 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

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.ManualSubscriberWithErrorCollection<A> - Class in org.reactivestreams.tck

IdentityProcessorVerification.TestSetup - Class in org.reactivestreams.tck

InfiniteHelperPublisher<T> - Class in org.reactivestreams.tck.flow.support

InfiniteHelperPublisher(Function<Integer, T>, Executor) - Constructor for class org.reactivestreams.tck.flow.support.InfiniteHelperPublisher

isCancelled() - Method in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

isClosed() - Method in class org.reactivestreams.tck.TestEnvironment.Latch

isCompleted() - Method in class org.reactivestreams.tck.TestEnvironment.Promise

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

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

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

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

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

L

lastT - Variable in class org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStage

lastT - Variable in class org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

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

M

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

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

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

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

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

Override and return lower value if your Publisher is only able to produce a known number of elements.

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

Override and return lower value if your Publisher is only able to produce a known number of elements.

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

Describes the tested implementation in terms of how many subscribers they can support.

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

N

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

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

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

newSubscriber() - Method in class org.reactivestreams.tck.IdentityProcessorVerification.TestSetup

next(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.Receptacle

nextElement() - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

nextElement(long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

nextElement(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.BlackholeSubscriberWithSubscriptionSupport

nextElement(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

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

nextElementOrEndOfStream() - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

nextElementOrEndOfStream(long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

nextElementOrEndOfStream(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

nextElements(long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

nextElements(long, long) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

nextElements(long, long, String) - Method in class org.reactivestreams.tck.TestEnvironment.BlackholeSubscriberWithSubscriptionSupport

nextElements(long, long, String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

nextElements(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

nextN(long, long, String) - Method in class org.reactivestreams.tck.TestEnvironment.Receptacle

nextOrEndOfStream(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.Receptacle

nextT() - Method in class org.reactivestreams.tck.IdentityProcessorVerification.TestSetup

nextT() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStage

nextT() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

NonFatal - Class in org.reactivestreams.tck.flow.support

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

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

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

notVerified() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

notVerified() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

notVerified(String) - Method in class org.reactivestreams.tck.IdentityProcessorVerification

notVerified(String) - Method in class org.reactivestreams.tck.PublisherVerification

notVerified(String) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

O

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

onComplete() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxSubscriberProxy

onComplete() - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

onComplete() - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriberWithSubscriptionSupport

onComplete() - Method in class org.reactivestreams.tck.TestEnvironment.TestSubscriber

onError(Throwable) - Method in class org.reactivestreams.tck.IdentityProcessorVerification.ManualSubscriberWithErrorCollection

onError(Throwable) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxSubscriberProxy

onError(Throwable) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriberWithSubscriptionSupport

onError(Throwable) - Method in class org.reactivestreams.tck.TestEnvironment.TestSubscriber

onNext(T) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxSubscriberProxy

onNext(T) - Method in class org.reactivestreams.tck.TestEnvironment.BlackholeSubscriberWithSubscriptionSupport

onNext(T) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

onNext(T) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriberWithSubscriptionSupport

onNext(T) - Method in class org.reactivestreams.tck.TestEnvironment.TestSubscriber

onSubscribe(Subscription) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxSubscriberProxy

onSubscribe(Subscription) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriberWithSubscriptionSupport

onSubscribe(Subscription) - Method in class org.reactivestreams.tck.TestEnvironment.TestSubscriber

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

optional_spec104_mustSignalOnErrorWhenFails() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Asks for an error Publisher that should call onSubscribe exactly once followed by a single call to onError() without receiving any requests and otherwise not throwing any exception.

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

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

optional_spec105_emptyStreamMustTerminateBySignallingOnComplete() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Asks for an empty Publisher (i.e., length 0) and verifies it completes in a timely manner.

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

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

optional_spec111_maySupportMultiSubscribe() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Asks for a single-element Publisher and subscribes to it twice, without consuming with either Subscriber instance (i.e., no requests are issued).

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

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

optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfront() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Asks for a short Publisher (length 3), subscribes 3 Subscribers to it, requests more than the length items upfront with each and verifies they all received the same items in the same order (but does not verify they all complete).

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

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

optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfrontAndCompleteAsExpected() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Asks for a short Publisher (length 3), subscribes 3 Subscribers to it, requests more than the length items upfront with each and verifies they all received the same items in the same order followed by an onComplete signal.

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

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

optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingOneByOne() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Asks for a short Publisher (length 5), subscribes 3 Subscribers to it, requests with different patterns and checks if all 3 received the same events in the same order.

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

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

optional_spec111_registeredSubscribersMustReceiveOnNextOrOnCompleteSignals() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Asks for a single-element Publisher and subscribes to it twice.

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

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

optional_spec309_requestNegativeNumberMaySignalIllegalArgumentExceptionWithSpecificMessage() - Method in interface org.reactivestreams.tck.flow.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.

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

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

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

optionalActivePublisherTest(long, boolean, PublisherVerification.PublisherTestRun<T>) - Method in class org.reactivestreams.tck.PublisherVerification

Test for feature that MAY be implemented.

optionalMultipleSubscribersTest(long, Function<Long, IdentityProcessorVerification.TestSetup>) - Method in class org.reactivestreams.tck.IdentityProcessorVerification

Test for feature that REQUIRES multiple subscribers to be supported by Publisher.

optionalSubscriberTestWithoutSetup(SubscriberWhiteboxVerification.TestStageTestRun) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

Test for feature that MAY be implemented.

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

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

P

pendingDemand - Variable in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

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

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

probe - Variable in class org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

probe() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

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

pub - Variable in class org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStage

pub - Variable in class org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

publisherExecutorService() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

publisherExecutorService() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

publisherExecutorService() - Method in class org.reactivestreams.tck.WithHelperPublisher

ExecutorService to be used by the provided helper Publisher

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

Return this value from PublisherVerification.maxElementsFromPublisher() to mark that the given Publisher, is not able to signal completion.

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

Provides tests for verifying Publisher specification rules.

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

Constructs a new verification class using the given env and configuration.

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

Constructs a new verification class using the given env and configuration.

PublisherVerification.PublisherTestRun<T> - Interface in org.reactivestreams.tck

PublisherVerificationRules - Interface in org.reactivestreams.tck.flow.support

Internal TCK use only.

puppet - Variable in class org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxSubscriberProbe

puppet() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

R

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(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

requestEndOfStream(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(long, String) - Method in class org.reactivestreams.tck.TestEnvironment.ManualSubscriber

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

requestNextElementOrEndOfStream() - 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

requestNextElementOrEndOfStream(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 interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Asks for a Publisher that should emit exactly one item and complete (both within a timeout specified by TestEnvironment.defaultTimeoutMillis()) in response to a request(1).

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

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

required_createPublisher3MustProduceAStreamOfExactly3Elements() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Asks for a Publisher that should emit exactly three items and complete (all within a timeout specified by TestEnvironment.defaultTimeoutMillis()).

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

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

required_exerciseWhiteboxHappyPath() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

required_exerciseWhiteboxHappyPath() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

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

Asks for a Processor that supports at least 2 Subscribers at once and checks requests from Subscribers will eventually lead to requests towards the upstream of the Processor.

required_spec101_subscriptionRequestMustResultInTheCorrectNumberOfProducedElements() - Method in interface org.reactivestreams.tck.flow.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_spec101_subscriptionRequestMustResultInTheCorrectNumberOfProducedElements() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

required_spec102_maySignalLessThanRequestedAndTerminateSubscription() - Method in interface org.reactivestreams.tck.flow.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_spec102_maySignalLessThanRequestedAndTerminateSubscription() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

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

Asks for a Processor that supports at least 2 Subscribers at once and checks if two Subscribers receive the same items and a terminal Exception.

required_spec105_mustSignalOnCompleteWhenFiniteStreamTerminates() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Asks for a short Publisher (i.e., length 3) and verifies, after requesting one by one, the sequence completes normally.

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

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

required_spec107_mustNotEmitFurtherSignalsOnceOnCompleteHasBeenSignalled() - Method in interface org.reactivestreams.tck.flow.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_spec107_mustNotEmitFurtherSignalsOnceOnCompleteHasBeenSignalled() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

required_spec109_mayRejectCallsToSubscribeIfPublisherIsUnableOrUnwillingToServeThemRejectionMustTriggerOnErrorAfterOnSubscribe() - Method in interface org.reactivestreams.tck.flow.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_mayRejectCallsToSubscribeIfPublisherIsUnableOrUnwillingToServeThemRejectionMustTriggerOnErrorAfterOnSubscribe() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

required_spec109_mustIssueOnSubscribeForNonNullSubscriber() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Asks for an empty Publisher and verifies if onSubscribe signal was emitted before any other onNext, onError or onComplete signal.

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

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

required_spec109_subscribeThrowNPEOnNullSubscriber() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Asks for an empty Publisher and calls subscribe on it with null that should result in a NullPointerException to be thrown.

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

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

required_spec201_blackbox_mustSignalDemandViaSubscriptionRequest() - Method in interface org.reactivestreams.tck.flow.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_blackbox_mustSignalDemandViaSubscriptionRequest() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

required_spec201_mustSignalDemandViaSubscriptionRequest() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

required_spec201_mustSignalDemandViaSubscriptionRequest() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

required_spec203_blackbox_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete() - Method in interface org.reactivestreams.tck.flow.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_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

required_spec203_blackbox_mustNotCallMethodsOnSubscriptionOrPublisherInOnError() - Method in interface org.reactivestreams.tck.flow.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_blackbox_mustNotCallMethodsOnSubscriptionOrPublisherInOnError() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnComplete() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnError() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

required_spec203_mustNotCallMethodsOnSubscriptionOrPublisherInOnError() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

required_spec205_blackbox_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal() - Method in interface org.reactivestreams.tck.flow.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_blackbox_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

required_spec205_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

required_spec205_mustCallSubscriptionCancelIfItAlreadyHasAnSubscriptionAndReceivesAnotherOnSubscribeSignal() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

required_spec208_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

required_spec208_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall() - Method in interface org.reactivestreams.tck.flow.support.SubscriberBlackboxVerificationRules

Asks for a Subscriber and expects it to handle onComplete independent of whether the Subscriber requests items or not.

required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

required_spec209_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall() - Method in interface org.reactivestreams.tck.flow.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_blackbox_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithoutPrecedingRequestCall() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

required_spec209_mustBePreparedToReceiveAnOnCompleteSignalWithPrecedingRequestCall() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

required_spec210_blackbox_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall() - Method in interface org.reactivestreams.tck.flow.support.SubscriberBlackboxVerificationRules

Asks for a Subscriber, signals onSubscribe followed by an onError synchronously.

required_spec210_blackbox_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

required_spec210_blackbox_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall() - Method in interface org.reactivestreams.tck.flow.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_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithoutPrecedingRequestCall() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

required_spec210_mustBePreparedToReceiveAnOnErrorSignalWithPrecedingRequestCall() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

required_spec213_blackbox_onError_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in interface org.reactivestreams.tck.flow.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_onError_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

required_spec213_blackbox_onNext_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in interface org.reactivestreams.tck.flow.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_onNext_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

required_spec213_blackbox_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in interface org.reactivestreams.tck.flow.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_blackbox_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

required_spec213_onError_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

required_spec213_onError_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

required_spec213_onNext_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in interface org.reactivestreams.tck.flow.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_onSubscribe_mustThrowNullPointerExceptionWhenParametersAreNull() - Method in interface org.reactivestreams.tck.flow.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_spec302_mustAllowSynchronousRequestCallsFromOnNextAndOnSubscribe() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Asks for a short Publisher (length 6), requests several times from within onSubscribe and then requests one-by-one from onNext.

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

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

required_spec303_mustNotAllowUnboundedRecursion() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Asks for a Publisher with length equal to the value returned by PublisherVerificationRules.required_validate_boundedDepthOfOnNextAndRequestRecursion() plus 1, calls request(1) externally and then from within onNext and checks if the stack depth did not increase beyond the amount permitted by PublisherVerificationRules.required_validate_boundedDepthOfOnNextAndRequestRecursion().

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

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

required_spec306_afterSubscriptionIsCancelledRequestMustBeNops() - Method in interface org.reactivestreams.tck.flow.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_spec306_afterSubscriptionIsCancelledRequestMustBeNops() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

required_spec307_afterSubscriptionIsCancelledAdditionalCancelationsMustBeNops() - Method in interface org.reactivestreams.tck.flow.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_spec307_afterSubscriptionIsCancelledAdditionalCancelationsMustBeNops() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

required_spec308_requestMustRegisterGivenNumberElementsToBeProduced() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

required_spec308_requestMustRegisterGivenNumberElementsToBeProduced() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

required_spec309_requestNegativeNumberMustSignalIllegalArgumentException() - Method in interface org.reactivestreams.tck.flow.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_requestNegativeNumberMustSignalIllegalArgumentException() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

required_spec309_requestZeroMustSignalIllegalArgumentException() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Asks for a short Publisher (length 10) and issues a request(0) 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_spec312_cancelMustMakeThePublisherToEventuallyStopSignaling() - Method in interface org.reactivestreams.tck.flow.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_spec312_cancelMustMakeThePublisherToEventuallyStopSignaling() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

required_spec313_cancelMustMakeThePublisherEventuallyDropAllReferencesToTheSubscriber() - Method in interface org.reactivestreams.tck.flow.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_spec313_cancelMustMakeThePublisherEventuallyDropAllReferencesToTheSubscriber() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

required_spec317_mustNotSignalOnErrorWhenPendingAboveLongMaxValue() - Method in interface org.reactivestreams.tck.flow.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_mustNotSignalOnErrorWhenPendingAboveLongMaxValue() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

required_spec317_mustSupportACumulativePendingElementCountUpToLongMaxValue() - Method in interface org.reactivestreams.tck.flow.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_mustSupportACumulativePendingElementCountUpToLongMaxValue() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

required_spec317_mustSupportAPendingElementCountUpToLongMaxValue() - Method in interface org.reactivestreams.tck.flow.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_spec317_mustSupportAPendingElementCountUpToLongMaxValue() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

required_validate_boundedDepthOfOnNextAndRequestRecursion() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Validates that the override of PublisherVerification.boundedDepthOfOnNextAndRequestRecursion() returns a positive value.

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

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

required_validate_maxElementsFromPublisher() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Validates that the override of PublisherVerification.maxElementsFromPublisher() returns a non-negative value.

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

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

run(Publisher<T>) - Method in interface org.reactivestreams.tck.PublisherVerification.PublisherTestRun

S

sendCompletion() - Method in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

sendError(Throwable) - Method in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

sendNext(T) - Method in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

sendNextTFromUpstream() - Method in class org.reactivestreams.tck.IdentityProcessorVerification.TestSetup

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

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

setUp() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

setUp() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

shutdownPublisherExecutorService() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

shutdownPublisherExecutorService() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

signalCancel() - Method in interface org.reactivestreams.tck.SubscriberWhiteboxVerification.SubscriberPuppet

Trigger cancel() on your Subscriber

signalNext() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStage

signalNext() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

SKIPPING_NO_ERROR_PUBLISHER_AVAILABLE - Static variable in class org.reactivestreams.tck.PublisherVerification

SKIPPING_OPTIONAL_TEST_FAILED - Static variable in class org.reactivestreams.tck.PublisherVerification

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

Override and return true in order to skip executing tests marked as Stochastic.

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

Override and return true in order to skip executing tests marked as Stochastic.

startPublisherExecutorService() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

startPublisherExecutorService() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

stochastic_spec103_mustSignalOnMethodsSequentially() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Asks for a short Publisher (i.e., length 10), repeatedly subscribes to this Publisher, requests items one by one and verifies the Publisher calls the onXXX methods non-overlappingly.

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

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

stochasticTest(int, Function<Integer, Void>) - Method in class org.reactivestreams.tck.PublisherVerification

Executes a given test body n times.

sub() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStage

sub() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

sub() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

subProxy() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStage

Proxy for the SubscriberBlackboxVerification.BlackboxTestStage.sub() Subscriber, providing certain assertions on methods being called on the Subscriber.

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

subscribe(Subscriber<? super T>) - Method in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

subscriber - Variable in class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

subscriber - Variable in class org.reactivestreams.tck.TestEnvironment.ManualPublisher

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

Provides tests for verifying Subscriber and Subscription specification rules, without any modifications to the tested implementation (also known as "Black Box" testing).

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

SubscriberBlackboxVerification.BlackboxTestStage - Class in org.reactivestreams.tck

SubscriberBlackboxVerificationRules - Interface in org.reactivestreams.tck.flow.support

Internal TCK use only.

SubscriberBufferOverflowException - Exception in org.reactivestreams.tck.flow.support

SubscriberBufferOverflowException() - Constructor for exception org.reactivestreams.tck.flow.support.SubscriberBufferOverflowException

SubscriberBufferOverflowException(String) - Constructor for exception org.reactivestreams.tck.flow.support.SubscriberBufferOverflowException

SubscriberBufferOverflowException(String, Throwable) - Constructor for exception org.reactivestreams.tck.flow.support.SubscriberBufferOverflowException

SubscriberBufferOverflowException(Throwable) - Constructor for exception org.reactivestreams.tck.flow.support.SubscriberBufferOverflowException

subscriberTest(SubscriberWhiteboxVerification.TestStageTestRun) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

Prepares subscriber and publisher pair (by subscribing the first to the latter), and then hands over the tests SubscriberWhiteboxVerification.WhiteboxTestStage over to the test.

subscriberTestWithoutSetup(SubscriberWhiteboxVerification.TestStageTestRun) - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

Provides a SubscriberWhiteboxVerification.WhiteboxTestStage without performing any additional setup, like the SubscriberWhiteboxVerification.subscriberTest(SubscriberWhiteboxVerification.TestStageTestRun) would.

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

Provides whitebox style tests for verifying Subscriber and Subscription specification rules.

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

SubscriberWhiteboxVerification.BlackboxProbe<T> - Class in org.reactivestreams.tck

SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T> - Class in org.reactivestreams.tck

This class is intented to be used as Subscriber decorator and should be used in pub.subscriber(...) calls, in order to allow intercepting calls on the underlying Subscriber.

SubscriberWhiteboxVerification.SubscriberProbe<T> - Interface in org.reactivestreams.tck

SubscriberWhiteboxVerification.SubscriberPuppet - Interface in org.reactivestreams.tck

Implement this puppet in your Whitebox style tests.

SubscriberWhiteboxVerification.SubscriberPuppeteer - Interface in org.reactivestreams.tck

SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T> - Class in org.reactivestreams.tck

SubscriberWhiteboxVerification.WhiteboxTestStage - Class in org.reactivestreams.tck

SubscriberWhiteboxVerificationRules - Interface in org.reactivestreams.tck.flow.support

Internal TCK use only.

T

tees - Variable in class org.reactivestreams.tck.SubscriberBlackboxVerification.BlackboxTestStage

tees - Variable in class org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

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

TestEnvironment - Class in org.reactivestreams.tck

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

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

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

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

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

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

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

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

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

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

TestEnvironment.BlackholeSubscriberWithSubscriptionSupport<T> - Class in org.reactivestreams.tck

Similar to TestEnvironment.ManualSubscriberWithSubscriptionSupport but does not accumulate values signalled via onNext, thus it can not be used to assert values signalled to this subscriber.

TestEnvironment.Latch - Class in org.reactivestreams.tck

Like a CountDownLatch, but resettable and with some convenience methods

TestEnvironment.ManualPublisher<T> - Class in org.reactivestreams.tck

TestEnvironment.ManualSubscriber<T> - Class in org.reactivestreams.tck

Subscriber implementation which can be steered by test code and asserted on.

TestEnvironment.ManualSubscriberWithSubscriptionSupport<T> - Class in org.reactivestreams.tck

TestEnvironment.Promise<T> - Class in org.reactivestreams.tck

TestEnvironment.Receptacle<T> - Class in org.reactivestreams.tck

TestEnvironment.TestSubscriber<T> - Class in org.reactivestreams.tck

TestException - Exception in org.reactivestreams.tck.flow.support

Exception used by the TCK to signal failures.

TestException() - Constructor for exception org.reactivestreams.tck.flow.support.TestException

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

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

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

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

triggerRequest(long) - Method in interface org.reactivestreams.tck.SubscriberWhiteboxVerification.SubscriberPuppet

Trigger request(elements) on your Subscriber

triggerRequest(Subscriber<? super T>) - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

Override this method if the Subscriber implementation you are verifying needs an external signal before it signals demand to its Publisher.

U

untested_spec106_mustConsiderSubscriptionCancelledAfterOnErrorOrOnCompleteHasBeenCalled() - Method in interface org.reactivestreams.tck.flow.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_spec106_mustConsiderSubscriptionCancelledAfterOnErrorOrOnCompleteHasBeenCalled() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

untested_spec107_mustNotEmitFurtherSignalsOnceOnErrorHasBeenSignalled() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Currently, this test is skipped, although it is possible to validate an error Publisher along the same lines as PublisherVerificationRules.required_spec107_mustNotEmitFurtherSignalsOnceOnCompleteHasBeenSignalled().

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

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

untested_spec108_possiblyCanceledSubscriptionShouldNotReceiveOnErrorOrOnCompleteSignals() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Currently, this test is skipped because there was no agreement on how to verify its "eventually" requirement.

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

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

untested_spec109_subscribeShouldNotThrowNonFatalThrowable() - Method in interface org.reactivestreams.tck.flow.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_spec109_subscribeShouldNotThrowNonFatalThrowable() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

untested_spec110_rejectASubscriptionRequestIfTheSameSubscriberSubscribesTwice() - Method in interface org.reactivestreams.tck.flow.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_spec110_rejectASubscriptionRequestIfTheSameSubscriberSubscribesTwice() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

untested_spec202_blackbox_shouldAsynchronouslyDispatch() - Method in interface org.reactivestreams.tck.flow.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_blackbox_shouldAsynchronouslyDispatch() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

untested_spec202_shouldAsynchronouslyDispatch() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

untested_spec202_shouldAsynchronouslyDispatch() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

untested_spec204_blackbox_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError() - Method in interface org.reactivestreams.tck.flow.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_blackbox_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

untested_spec204_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

untested_spec204_mustConsiderTheSubscriptionAsCancelledInAfterRecievingOnCompleteOrOnError() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

untested_spec206_blackbox_mustCallSubscriptionCancelIfItIsNoLongerValid() - Method in interface org.reactivestreams.tck.flow.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_blackbox_mustCallSubscriptionCancelIfItIsNoLongerValid() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

untested_spec206_mustCallSubscriptionCancelIfItIsNoLongerValid() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

untested_spec206_mustCallSubscriptionCancelIfItIsNoLongerValid() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

untested_spec207_blackbox_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization() - Method in interface org.reactivestreams.tck.flow.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_blackbox_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

untested_spec207_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

untested_spec207_mustEnsureAllCallsOnItsSubscriptionTakePlaceFromTheSameThreadOrTakeCareOfSynchronization() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

untested_spec208_blackbox_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel() - Method in interface org.reactivestreams.tck.flow.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 onNexts after such cancel.

untested_spec208_blackbox_mustBePreparedToReceiveOnNextSignalsAfterHavingCalledSubscriptionCancel() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

untested_spec211_blackbox_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents() - Method in interface org.reactivestreams.tck.flow.support.SubscriberBlackboxVerificationRules

Currently, this test is skipped because it would require analyzing what the Subscriber implementation does.

untested_spec211_blackbox_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

untested_spec211_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

untested_spec211_mustMakeSureThatAllCallsOnItsMethodsHappenBeforeTheProcessingOfTheRespectiveEvents() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

untested_spec212_blackbox_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality() - Method in interface org.reactivestreams.tck.flow.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_blackbox_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

untested_spec212_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality_specViolation() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

untested_spec212_mustNotCallOnSubscribeMoreThanOnceBasedOnObjectEquality_specViolation() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

untested_spec213_blackbox_failingOnSignalInvocation() - Method in interface org.reactivestreams.tck.flow.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_blackbox_failingOnSignalInvocation() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

untested_spec213_failingOnSignalInvocation() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

untested_spec213_failingOnSignalInvocation() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

untested_spec301_blackbox_mustNotBeCalledOutsideSubscriberContext() - Method in interface org.reactivestreams.tck.flow.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_blackbox_mustNotBeCalledOutsideSubscriberContext() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

untested_spec301_mustNotBeCalledOutsideSubscriberContext() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

untested_spec301_mustNotBeCalledOutsideSubscriberContext() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

untested_spec304_requestShouldNotPerformHeavyComputations() - Method in interface org.reactivestreams.tck.flow.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_spec304_requestShouldNotPerformHeavyComputations() - Method in class org.reactivestreams.tck.IdentityProcessorVerification

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

untested_spec305_cancelMustNotSynchronouslyPerformHeavyComputation() - Method in interface org.reactivestreams.tck.flow.support.PublisherVerificationRules

Currently, this test is skipped because there is no reliable agreed upon way to detect a heavy computation.

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

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

untested_spec308_blackbox_requestMustRegisterGivenNumberElementsToBeProduced() - Method in interface org.reactivestreams.tck.flow.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_spec308_blackbox_requestMustRegisterGivenNumberElementsToBeProduced() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

untested_spec310_blackbox_requestMaySynchronouslyCallOnNextOnSubscriber() - Method in interface org.reactivestreams.tck.flow.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_requestMaySynchronouslyCallOnNextOnSubscriber() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

untested_spec310_requestMaySynchronouslyCallOnNextOnSubscriber() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

untested_spec311_blackbox_requestMaySynchronouslyCallOnCompleteOrOnError() - Method in interface org.reactivestreams.tck.flow.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_blackbox_requestMaySynchronouslyCallOnCompleteOrOnError() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

untested_spec311_requestMaySynchronouslyCallOnCompleteOrOnError() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

untested_spec311_requestMaySynchronouslyCallOnCompleteOrOnError() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

untested_spec314_blackbox_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists() - Method in interface org.reactivestreams.tck.flow.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_blackbox_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

untested_spec314_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

untested_spec314_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

untested_spec315_blackbox_cancelMustNotThrowExceptionAndMustSignalOnError() - Method in interface org.reactivestreams.tck.flow.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_blackbox_cancelMustNotThrowExceptionAndMustSignalOnError() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

untested_spec315_cancelMustNotThrowExceptionAndMustSignalOnError() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

untested_spec315_cancelMustNotThrowExceptionAndMustSignalOnError() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

untested_spec316_blackbox_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber() - Method in interface org.reactivestreams.tck.flow.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_blackbox_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber() - Method in class org.reactivestreams.tck.SubscriberBlackboxVerification

untested_spec316_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber() - Method in interface org.reactivestreams.tck.flow.support.SubscriberWhiteboxVerificationRules

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

untested_spec316_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification

V

value() - Method in class org.reactivestreams.tck.TestEnvironment.Promise

verifyNoAsyncErrors() - Method in class org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

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

Waits for TestEnvironment.defaultTimeoutMillis() and then verifies that no asynchronous errors were signalled pior to, or during that time (by calling flop()).

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

This version of verifyNoAsyncErrors should be used when errors still could be signalled asynchronously during TestEnvironment.defaultTimeoutMillis() time.

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

Verifies that no asynchronous errors were signalled pior to calling this method (by calling flop()).

W

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

Additional test for Publisher in error state

WhiteboxSubscriberProbe(TestEnvironment, TestEnvironment.Promise<Subscriber<? super T>>) - Constructor for class org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxSubscriberProbe

WhiteboxTestStage(TestEnvironment) - Constructor for class org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

WhiteboxTestStage(TestEnvironment, boolean) - Constructor for class org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxTestStage

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

Type which is able to create elements based on a seed id value.

WithHelperPublisher() - Constructor for class org.reactivestreams.tck.WithHelperPublisher

A B C D E F G H I L M N O P R S T U V W