Uses of Package
io.helidon.common.reactive
Package
Description
HTTP APIs and implementations usable by both server and client side of the HTTP story.
Common reactive library for Helidon projects.
Reactive Database API for Helidon.
Helper classes to use in various implementations.
Health check support for Helidon DB Client.
Helidon DB integration for reactive mongoDB.
Tracing support for Helidon DB.
Fault tolerance for Helidon SE reactive implementation.
Common classes for accessing JSON based REST APIs of third party systems.
Vault integration.
AppRole authentication method for Vault.
Common classes for Vault integration.
Vault authentication method for Kubernetes.
Token authentication method for Vault.
Cubbyhole secret engine support for Vault.
Vault's Database Secrets Engine support.
Vault's KV1 Secrets Engine support.
Vault's Key/value version 2 Secrets Engine support.
Vault's PKI Secrets Engine support.
Vault transit secrets.
Sys operations for Vault.
MicroProfile Long Running Actions Coordinator client spi.
MicroProfile Long Running Actions Narayana Coordinator client.
Common classes for processing content with a specific
MediaType
.Helidon Media MultiPart.
Helidon Reactive Messaging.
Helidon messaging mock connector for testing purposes.
Security
Vault operation backed by configuration.
Mapper that retrieves roles from IDCS server and maps them to user subject.
Open ID Connect (OIDC) classes usable from all OIDC related components.
Security component's SPI.
A reactive client for rest calls.
Client metrics service.
Client service propagation service.
This package provides extensibility for the
WebClient
.Client tracing propagation service.
Reactive web server API.
-
ClassDescriptionRepresents a
Flow.Publisher
emitting zero or more items, optionally followed by an error or completion.Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error.Decorated publisher that allows subscribing to individual events with java functions. -
ClassDescriptionMakes intentional blocking when waiting for
CompletableFuture
more convenient withAwaitable.await()
andAwaitable.await(long, java.util.concurrent.TimeUnit)
methods.Emitting publisher for manual publishing with built-in buffer for handling backpressure.Fluent API builder to createBufferedEmittingPublisher
.A collector accumulates the items provided whenCollector.collect(java.lang.Object)
is invoked and makes them available in a single container object withCollector.value()
.CompletionStage
wrapper enriched withAwaitable
.Concat streams to one.Emitting publisher for manual publishing on the same thread.Fluent API builder for creating aMulti
from aReadableByteChannel
.Fluent API builder for creating aMulti
from anInputStream
.Fluent API builder for creating a subscriber consumingMulti<ByteBuffer>
toWritableByteChannel
.Fluent API builder forOutputStreamMulti
.Represents aFlow.Publisher
emitting zero or more items, optionally followed by an error or completion.Deprecated, for removal: This API element is subject to removal in a future version.Intercept 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.Output stream thatFlow.Publisher
publishes any data written to it asByteBuffer
events.Defines delay for next read/poll operation in a pollingpublisher
.WrapperFlow.Subscriber
ensuringOnSubscribe
,onNext
,onError
andonComplete
to be signaled serially.Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error.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 onFlow.Subscription
s. -
ClassDescriptionRepresents a
Flow.Publisher
emitting zero or more items, optionally followed by an error or completion.Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error.Decorated publisher that allows subscribing to individual events with java functions. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionMakes intentional blocking when waiting for
CompletableFuture
more convenient withAwaitable.await()
andAwaitable.await(long, java.util.concurrent.TimeUnit)
methods. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error.Decorated publisher that allows subscribing to individual events with java functions. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
emitting zero or more items, optionally followed by an error or completion.Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
emitting zero or more items, optionally followed by an error or completion.Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
emitting zero or more items, optionally followed by an error or completion.Defines delay for next read/poll operation in a pollingpublisher
.Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error.Decorated publisher that allows subscribing to individual events with java functions. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
emitting zero or more items, optionally followed by an error or completion. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
ClassDescriptionRepresents a
Flow.Publisher
that may: signal one item then completes, complete without an item or signal an error.
OutputStreamMulti
instead