All Classes Interface Summary Class Summary Enum Summary Exception Summary
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> |
|
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> |
|
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> |
|
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 |
|
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> |
|
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.
|