All Classes

Class	Description
AsyncIterablePublisher<T>	AsyncIterablePublisher is an implementation of Reactive Streams `Publisher` which executes asynchronously, using a provided `Executor` and produces elements from a given `Iterable` in a "unicast" configuration to its `Subscribers`.
AsyncIterablePublisher.Cancel
AsyncIterablePublisher.Request
AsyncIterablePublisher.Send
AsyncIterablePublisher.Signal
AsyncIterablePublisher.Subscribe
AsyncSubscriber<T>	AsyncSubscriber is an implementation of Reactive Streams `Subscriber`, it runs asynchronously (on an Executor), requests one element at a time, and invokes a user-defined method to process each element.
AsyncSubscriber.OnComplete
AsyncSubscriber.OnError
AsyncSubscriber.OnNext<T>
AsyncSubscriber.OnSubscribe
AsyncSubscriber.Signal
FlowAdapters	Bridge between Reactive Streams API and the Java 9 Flow API.
FlowAdapters.FlowPublisherFromReactive<T>	Flow Publisher that wraps a Reactive Streams Publisher.
FlowAdapters.FlowToReactiveProcessor<T,U>	Wraps a Reactive Streams Processor and forwards methods of the Flow Processor to it.
FlowAdapters.FlowToReactiveSubscriber<T>	Wraps a Reactive Streams Subscriber and forwards methods of the Flow Subscriber to it.
FlowAdapters.FlowToReactiveSubscription	Wraps a Reactive Streams Subscription and converts the calls to a Flow Subscription.
FlowAdapters.ReactivePublisherFromFlow<T>	Reactive Streams Publisher that wraps a Flow Publisher.
FlowAdapters.ReactiveToFlowProcessor<T,U>	Wraps a Flow Processor and forwards methods of the Reactive Streams Processor to it.
FlowAdapters.ReactiveToFlowSubscriber<T>	Wraps a Flow Subscriber and forwards methods of the Reactive Streams Subscriber to it.
FlowAdapters.ReactiveToFlowSubscription	Wraps a Flow Subscription and converts the calls to a Reactive Streams Subscription.
FlowPublisherVerification<T>	Provides tests for verifying a Java 9+ Flow.Publisher specification rules.
FlowSubscriberBlackboxVerification<T>	Provides tests for verifying Flow.Subscriber and Flow.Subscription specification rules, without any modifications to the tested implementation (also known as "Black Box" testing).
FlowSubscriberWhiteboxVerification<T>	Provides whitebox style tests for verifying Flow.Subscriber and Flow.Subscription specification rules.
Function<In,Out>
HelperPublisher<T>
IdentityFlowProcessorVerification<T>
IdentityProcessorVerification<T>
InfiniteHelperPublisher<T>
InfiniteIncrementNumberPublisher
NonFatal	Copy of scala.control.util.NonFatal in order to not depend on scala-library
NumberIterablePublisher
Optional<T>
Optional.Some<T>
Processor<T,R>	A Processor represents a processing stage—which is both a Subscriber and a Publisher and obeys the contracts of both.
Publisher<T>	A Publisher is a provider of a potentially unbounded number of sequenced elements, publishing them according to the demand received from its Subscriber(s).
PublisherVerification<T>	Provides tests for verifying Publisher specification rules.
PublisherVerification.PublisherTestRun<T>
PublisherVerificationRules	Internal TCK use only.
RangePublisher	A synchronous implementation of the Publisher that can be subscribed to multiple times and each individual subscription will receive range of monotonically increasing integer values on demand.
RangePublisher.RangeSubscription	A Subscription implementation that holds the current downstream requested amount and responds to the downstream's request() and cancel() calls.
Subscriber<T>	Will receive call to Subscriber.onSubscribe(Subscription) once after passing an instance of Subscriber to subscribe(Subscriber).
SubscriberBlackboxVerification<T>	Provides tests for verifying Subscriber and Subscription specification rules, without any modifications to the tested implementation (also known as "Black Box" testing).
SubscriberBlackboxVerificationRules	Internal TCK use only.
SubscriberBufferOverflowException
SubscriberWhiteboxVerification<T>	Provides whitebox style tests for verifying Subscriber and Subscription specification rules.
SubscriberWhiteboxVerification.BlackboxProbe<T>
SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T>	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>
SubscriberWhiteboxVerification.SubscriberPuppet	Implement this puppet in your Whitebox style tests.
SubscriberWhiteboxVerification.SubscriberPuppeteer
SubscriberWhiteboxVerification.WhiteboxSubscriberProbe<T>
SubscriberWhiteboxVerificationRules	Internal TCK use only.
Subscription	A Subscription represents a one-to-one lifecycle of a Subscriber subscribing to a Publisher.
SyncSubscriber<T>	SyncSubscriber is an implementation of Reactive Streams `Subscriber`, it runs synchronously (on the Publisher's thread) and requests one element at a time and invokes a user-defined method to process each element.
TestEnvironment
TestEnvironment.BlackholeSubscriberWithSubscriptionSupport<T>	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	Like a CountDownLatch, but resettable and with some convenience methods
TestEnvironment.Latch.ExpectedClosedLatchException
TestEnvironment.Latch.ExpectedOpenLatchException
TestEnvironment.ManualPublisher<T>
TestEnvironment.ManualSubscriber<T>	Subscriber implementation which can be steered by test code and asserted on.
TestEnvironment.ManualSubscriberWithSubscriptionSupport<T>
TestEnvironment.Promise<T>
TestEnvironment.Receptacle<T>
TestEnvironment.TestSubscriber<T>
TestException	Exception used by the TCK to signal failures.
WithHelperPublisher<T>	Type which is able to create elements based on a seed id value.