Module io.helidon.common.reactive

Package io.helidon.common.reactive

Common reactive library for Helidon projects.

See Also:

Flow, Multi, IoMulti

Interface Summary

Interface	Description
Awaitable<T>	Makes intentional blocking when waiting for CompletableFuture more convenient with Awaitable.await() and Awaitable.await(long, java.util.concurrent.TimeUnit) methods.
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().
IoMulti	Create reactive stream from standard IO resources.
Multi<T>	Represents a Flow.Publisher emitting zero or more items, optionally followed by an error or completion.
OptionalCompletionStage<T>	A completion stage that allows processing of cases when the element is present and when not.
RetrySchema	Defines delay for next read/poll operation in a polling publisher.
Single<T>	Represents a Flow.Publisher that may: signal one item then completes, complete without an item or signal an error.
Subscribable<T>	Decorated publisher that allows subscribing to individual events with java functions.

Class Summary

Class	Description
BufferedEmittingPublisher<T>	Emitting publisher for manual publishing with built-in buffer for handling backpressure.
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.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.
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.
OutputStreamMulti	Output stream that Flow.Publisher publishes any data written to it as ByteBuffer events.
RequestedCounter	Requested event counter.
SequentialSubscriber<T>	Wrapper Flow.Subscriber ensuring OnSubscribe, onNext, onError and onComplete to be signaled serially.
SingleSubscriberHolder<T>	A subscriber container that accepts only a single, one-time subscriber registration.
StreamValidationUtils	Helper methods for stream validation.

Enum Summary

Enum	Description
SubscriptionHelper	Helper enum with a singleton cancellation indicator and utility methods to perform atomic actions on Flow.Subscriptions.