Uses of Package
Common reactive library for Helidon projects.
Helidon Reactive Messaging.
Helidon messaging mock connector for testing purposes.
ClassDescriptionMakes intentional blocking when waiting for
CompletableFuturemore convenient with
Awaitable.await(long, java.util.concurrent.TimeUnit)methods.Emitting publisher for manual publishing with built-in buffer for handling backpressure.Fluent API builder to create
BufferedEmittingPublisher.Concat streams to one.Emitting publisher for manual publishing on the same thread.Fluent API builder for creating a subscriber consuming
WritableByteChannel.Fluent API builder for
OutputStreamMulti.Deprecated, for removal: This API element is subject to removal in a future version.please use
OutputStreamMultiinsteadIntercept the calls to the various Flow interface methods and calls the appropriate user callbacks.Multi tapped publisher builder to register custom callbacks.A completion stage that allows processing of cases when the element is present and when not.Defines delay for next read/poll operation in a polling
onCompleteto be signaled serially.Decorated publisher that allows subscribing to individual events with java functions.Helper enum with a singleton cancellation indicator and utility methods to perform atomic actions on