Module io.helidon.common.reactive

Package io.helidon.common.reactive

package io.helidon.common.reactive

Common reactive library for Helidon projects.

See Also:

• Flow
• Multi
• IoMulti

Related Packages

Module	Package	Description
io.helidon.common	io.helidon.common	Common utilities for Helidon projects.

Class	Description
Awaitable<T>	Makes intentional blocking when waiting for CompletableFuture more convenient with Awaitable.await() and Awaitable.await(long, java.util.concurrent.TimeUnit) methods.
BufferedEmittingPublisher<T>	Emitting publisher for manual publishing with built-in buffer for handling backpressure.
BufferedEmittingPublisher.Builder<T>	Fluent API builder to create BufferedEmittingPublisher.
Collector<T,U>	A collector accumulates the items provided when Collector.collect(java.lang.Object) is invoked and makes them available in a single container object with Collector.value().
CompletionAwaitable<T>	CompletionStage wrapper enriched with Awaitable.
CompletionSingle<T>	Single as CompletionStage.
ConcatPublisher<T>	Concat streams to one.
EmittingPublisher<T>	Emitting publisher for manual publishing on the same thread.
IoMulti	Create reactive stream from standard IO resources.
IoMulti.MultiFromByteChannelBuilder	Fluent API builder for creating a Multi from a ReadableByteChannel.
IoMulti.MultiFromInputStreamBuilder	Fluent API builder for creating a Multi from an InputStream.
IoMulti.MultiToByteChannelBuilder	Fluent API builder for creating a subscriber consuming Multi<ByteBuffer> to WritableByteChannel.
IoMulti.OutputStreamMultiBuilder	Fluent API builder for OutputStreamMulti.
Multi<T>	Represents a Flow.Publisher emitting zero or more items, optionally followed by an error or completion.
MultiFromOutputStream	Deprecated, for removal: This API element is subject to removal in a future version. please use OutputStreamMulti instead
MultiTappedPublisher<T>	Intercept the calls to the various Flow interface methods and calls the appropriate user callbacks.
MultiTappedPublisher.Builder<T>	Multi tapped publisher builder to register custom callbacks.
OptionalCompletionStage<T>	A completion stage that allows processing of cases when the element is present and when not.
OutputStreamMulti	Output stream that Flow.Publisher publishes any data written to it as ByteBuffer events.
RequestedCounter	Requested event counter.
RetrySchema	Defines delay for next read/poll operation in a polling publisher.
SequentialSubscriber<T>	Wrapper Flow.Subscriber ensuring OnSubscribe, onNext, onError and onComplete to be signaled serially.
Single<T>	Represents a Flow.Publisher that may: signal one item then completes, complete without an item or signal an error.
SingleSubscriberHolder<T>	A subscriber container that accepts only a single, one-time subscriber registration.
StreamValidationUtils	Helper methods for stream validation.
Subscribable<T>	Decorated publisher that allows subscribing to individual events with java functions.
SubscriptionHelper	Helper enum with a singleton cancellation indicator and utility methods to perform atomic actions on Flow.Subscriptions.