Uses of Package
io.helidon.common.reactive
-
Packages that use io.helidon.common.reactive Package Description io.helidon.common.http HTTP APIs and implementations usable by both server and client side of the HTTP story.io.helidon.common.reactive Common reactive library for Helidon projects.io.helidon.dbclient Reactive Database API for Helidon.io.helidon.dbclient.common Helper classes to use in various implementations.io.helidon.dbclient.health Health check support for Helidon DB Client.io.helidon.dbclient.mongodb Helidon DB integration for reactive mongoDB.io.helidon.dbclient.tracing Tracing support for Helidon DB.io.helidon.faulttolerance Fault tolerance for Helidon SE reactive implementation.io.helidon.integrations.common.rest Common classes for accessing JSON based REST APIs of third party systems.io.helidon.integrations.oci.atp OCI ATP integration.io.helidon.integrations.oci.connect Classes needed for OCI to connect to service API.io.helidon.integrations.oci.objectstorage OCI Object Storage integration.io.helidon.integrations.oci.telemetry Integration with OCI Telemetry.io.helidon.integrations.oci.vault Integration with OCI Vault REST API including the KMS encryption and digest support.io.helidon.integrations.vault Vault integration.io.helidon.integrations.vault.auths.approle AppRole authentication method for Vault.io.helidon.integrations.vault.auths.common Common classes for Vault integration.io.helidon.integrations.vault.auths.k8s Vault authentication method for Kubernetes.io.helidon.integrations.vault.auths.token Token authentication method for Vault.io.helidon.integrations.vault.secrets.cubbyhole Cubbyhole secret engine support for Vault.io.helidon.integrations.vault.secrets.database Vault's Database Secrets Engine support.io.helidon.integrations.vault.secrets.kv1 Vault's KV1 Secrets Engine support.io.helidon.integrations.vault.secrets.kv2 Vault's Key/value version 2 Secrets Engine support.io.helidon.integrations.vault.secrets.pki Vault's PKI Secrets Engine support.io.helidon.integrations.vault.secrets.transit Vault transit secrets.io.helidon.integrations.vault.sys Sys operations for Vault.io.helidon.lra.coordinator.client MicroProfile Long Running Actions Coordinator client spi.io.helidon.lra.coordinator.client.narayana MicroProfile Long Running Actions Narayana Coordinator client.io.helidon.media.common Common classes for processing content with a specificMediaType
.io.helidon.media.multipart Helidon Media MultiPart.io.helidon.messaging Helidon Reactive Messaging.io.helidon.security Securityio.helidon.security.providers.config.vault Vault operation backed by configuration.io.helidon.security.providers.idcs.mapper Mapper that retrieves roles from IDCS server and maps them to user subject.io.helidon.security.providers.oidc.common Open ID Connect (OIDC) classes usable from all OIDC related components.io.helidon.security.spi Security component's SPI.io.helidon.webclient A reactive client for rest calls.io.helidon.webclient.context.propagation Propagation of context values across network using HTTP Headers.io.helidon.webclient.metrics Client metrics service.io.helidon.webclient.security Client service propagation service.io.helidon.webclient.spi This package provides extensibility for theWebClient
.io.helidon.webclient.tracing Client tracing propagation service.io.helidon.webserver Reactive web server API. -
Classes in io.helidon.common.reactive used by io.helidon.common.http Class Description Multi Represents aFlow.Publisher
emitting zero or more items, optionally followed by an error or completion.Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error.Subscribable Decorated publisher that allows subscribing to individual events with java functions. -
Classes in io.helidon.common.reactive used by io.helidon.common.reactive Class Description Awaitable Makes intentional blocking when waiting forCompletableFuture
more convenient withAwaitable.await()
andAwaitable.await(long, java.util.concurrent.TimeUnit)
methods.BufferedEmittingPublisher Emitting publisher for manual publishing with built-in buffer for handling backpressure.Collector A collector accumulates the items provided whenCollector.collect(java.lang.Object)
is invoked and makes them available in a single container object withCollector.value()
.CompletionAwaitable CompletionStage
wrapper enriched withAwaitable
.ConcatPublisher Concat streams to one.EmittingPublisher Emitting publisher for manual publishing on the same thread.IoMulti.MultiFromByteChannelBuilder Fluent API builder for creating aMulti
from aReadableByteChannel
.IoMulti.MultiFromInputStreamBuilder Fluent API builder for creating aMulti
from anInputStream
.IoMulti.MultiToByteChannelBuilder Fluent API builder for creating a subscriber consumingMulti<ByteBuffer>
toWritableByteChannel
.IoMulti.OutputStreamMultiBuilder Fluent API builder forOutputStreamMulti
.Multi Represents aFlow.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 useOutputStreamMulti
insteadMultiTappedPublisher Intercept the calls to the various Flow interface methods and calls the appropriate user callbacks.MultiTappedPublisher.Builder Multi tapped publisher builder to register custom callbacks.OptionalCompletionStage A completion stage that allows processing of cases when the element is present and when not.OutputStreamMulti Output stream thatFlow.Publisher
publishes any data written to it asByteBuffer
events.RetrySchema Defines delay for next read/poll operation in a pollingpublisher
.SequentialSubscriber WrapperFlow.Subscriber
ensuringOnSubscribe
,onNext
,onError
andonComplete
to be signaled serially.Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error.Subscribable 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 onFlow.Subscription
s. -
Classes in io.helidon.common.reactive used by io.helidon.dbclient Class Description Multi Represents aFlow.Publisher
emitting zero or more items, optionally followed by an error or completion.Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error.Subscribable Decorated publisher that allows subscribing to individual events with java functions. -
Classes in io.helidon.common.reactive used by io.helidon.dbclient.common Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.dbclient.health Class Description Awaitable Makes intentional blocking when waiting forCompletableFuture
more convenient withAwaitable.await()
andAwaitable.await(long, java.util.concurrent.TimeUnit)
methods. -
Classes in io.helidon.common.reactive used by io.helidon.dbclient.mongodb Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error.Subscribable Decorated publisher that allows subscribing to individual events with java functions. -
Classes in io.helidon.common.reactive used by io.helidon.dbclient.tracing Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.faulttolerance Class Description Multi Represents aFlow.Publisher
emitting zero or more items, optionally followed by an error or completion.Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.common.rest Class Description Multi Represents aFlow.Publisher
emitting zero or more items, optionally followed by an error or completion.Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.oci.atp Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.oci.connect Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.oci.objectstorage Class Description Multi Represents aFlow.Publisher
emitting zero or more items, optionally followed by an error or completion.Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.oci.telemetry Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.oci.vault Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.vault Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.vault.auths.approle Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.vault.auths.common Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.vault.auths.k8s Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.vault.auths.token Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.vault.secrets.cubbyhole Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.vault.secrets.database Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.vault.secrets.kv1 Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.vault.secrets.kv2 Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.vault.secrets.pki Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.vault.secrets.transit Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.integrations.vault.sys Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.lra.coordinator.client Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.lra.coordinator.client.narayana Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.media.common Class Description Multi Represents aFlow.Publisher
emitting zero or more items, optionally followed by an error or completion.RetrySchema Defines delay for next read/poll operation in a pollingpublisher
.Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error.Subscribable Decorated publisher that allows subscribing to individual events with java functions. -
Classes in io.helidon.common.reactive used by io.helidon.media.multipart Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.messaging Class Description Multi Represents aFlow.Publisher
emitting zero or more items, optionally followed by an error or completion. -
Classes in io.helidon.common.reactive used by io.helidon.security Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.security.providers.config.vault Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.security.providers.idcs.mapper Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.security.providers.oidc.common Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.security.spi Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.webclient Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.webclient.context.propagation Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.webclient.metrics Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.webclient.security Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.webclient.spi Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.webclient.tracing Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error. -
Classes in io.helidon.common.reactive used by io.helidon.webserver Class Description Single Represents aFlow.Publisher
that may: signal one item then completes, complete without an item or signal an error.