Uses of Interface
Common reactive library for Helidon projects.
Uses of Subscribable in io.helidon.common.reactiveModifier and TypeInterfaceDescription
Flow.Publisheremitting zero or more items, optionally followed by an error or completion.
Flow.Publisherthat may: signal one item then completes, complete without an item or signal an error.Modifier and TypeClassDescription
classSingle as CompletionStage.
final classConcat streams to one.
classDeprecated, for removal: This API element is subject to removal in a future version.please use
final classIntercept the calls to the various Flow interface methods and calls the appropriate user callbacks.
classModifier and TypeMethodDescriptionSignals the default item supplied by specified supplier if the upstream is empty.Signals the default item if the upstream is empty.Transform item with supplied function and flatten resulting
Flow.Publisherto downstream.Transform item with supplied function and flatten resulting
Iterableto downstream.Re-emit the upstream's signals to the downstream on the given executor's thread.Executes given
Runnablewhen a cancel signal is received.Executes given
Runnablewhen onComplete signal is received.Resume stream from single item if onComplete signal is intercepted.Resume stream from supplied publisher if onComplete signal is intercepted.Executes given
Runnablewhen onError signal is received.
Functionproviding one item to be submitted as onNext in case of onError signal is received.Subscribable.
(Function<? super Throwable, ? extends Flow.Publisher<? extends T>> onError)Resume stream from supplied publisher if onError signal is intercepted.Executes given
Runnablewhen any of signals onComplete, onCancel or onError is received.Invoke provided consumer for every item in stream.Subscribable.
(long count)Retry a failing upstream at most the given number of times before giving up.Retry a failing upstream if the predicate returns true.Subscribable.
(BiFunction<? super Throwable, ? super Long, ? extends Flow.Publisher<U>> whenFunction)Retry a failing upstream when the given function returns a publisher that signals an item.Relay upstream items until the other source signals an item or completes.Signals a
TimeoutExceptionif the upstream doesn't signal the next item, error or completion within the specified time.