Uses of Interface
io.helidon.common.reactive.Subscribable
Packages that use Subscribable
-
Uses of Subscribable in io.helidon.common.reactive
Subinterfaces of Subscribable in io.helidon.common.reactiveModifier and TypeInterfaceDescriptioninterfaceMulti<T>Represents aFlow.Publisheremitting zero or more items, optionally followed by an error or completion.interfaceSingle<T>Represents aFlow.Publisherthat may: signal one item then completes, complete without an item or signal an error.Classes in io.helidon.common.reactive that implement SubscribableModifier and TypeClassDescriptionclassSingle as CompletionStage.final classConcat streams to one.classDeprecated, for removal: This API element is subject to removal in a future version.final classIntercept the calls to the various Flow interface methods and calls the appropriate user callbacks.classOutput stream thatFlow.Publisherpublishes any data written to it asByteBufferevents.Methods in io.helidon.common.reactive that return SubscribableModifier and TypeMethodDescriptionSubscribable.defaultIfEmpty(Supplier<? extends T> supplier) Signals the default item supplied by specified supplier if the upstream is empty.Subscribable.defaultIfEmpty(T defaultItem) Signals the default item if the upstream is empty.<U> Subscribable<U> Subscribable.flatMap(Function<? super T, ? extends Flow.Publisher<? extends U>> mapper) Transform item with supplied function and flatten resultingFlow.Publisherto downstream.<U> Subscribable<U> Subscribable.flatMapIterable(Function<? super T, ? extends Iterable<? extends U>> mapper) Transform item with supplied function and flatten resultingIterableto downstream.<U> Subscribable<U> Re-emit the upstream's signals to the downstream on the given executor's thread.Executes givenRunnablewhen a cancel signal is received.Subscribable.onComplete(Runnable onComplete) Executes givenRunnablewhen onComplete signal is received.Subscribable.onCompleteResume(T item) Resume stream from single item if onComplete signal is intercepted.Subscribable.onCompleteResumeWith(Flow.Publisher<? extends T> publisher) Resume stream from supplied publisher if onComplete signal is intercepted.Executes givenRunnablewhen onError signal is received.Subscribable.onErrorResume(Function<? super Throwable, ? extends T> onError) Functionproviding one item to be submitted as onNext in case of onError signal is received.Subscribable.onErrorResumeWith(Function<? super Throwable, ? extends Flow.Publisher<? extends T>> onError) Resume stream from supplied publisher if onError signal is intercepted.Subscribable.onTerminate(Runnable onTerminate) Executes givenRunnablewhen any of signals onComplete, onCancel or onError is received.Invoke provided consumer for every item in stream.Subscribable.retry(long count) Retry a failing upstream at most the given number of times before giving up.Subscribable.retry(BiPredicate<? super Throwable, ? super Long> predicate) Retry a failing upstream if the predicate returns true.<U> Subscribable<T> Subscribable.retryWhen(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.<U> Subscribable<T> Subscribable.takeUntil(Flow.Publisher<U> other) Relay upstream items until the other source signals an item or completes.Subscribable.timeout(long timeout, TimeUnit unit, ScheduledExecutorService executor) Signals aTimeoutExceptionif the upstream doesn't signal the next item, error or completion within the specified time.
OutputStreamMultiinstead