Uses of Interface
io.helidon.common.reactive.Subscribable

Packages that use Subscribable

Package	Description
io.helidon.common.reactive	Common reactive library for Helidon projects.

Uses of Subscribable in io.helidon.common.reactive

Subinterfaces of Subscribable in io.helidon.common.reactive

Modifier and Type	Interface	Description
interface	Multi<T>	Represents a Flow.Publisher emitting zero or more items, optionally followed by an error or completion.
interface	Single<T>	Represents a Flow.Publisher that may: signal one item then completes, complete without an item or signal an error.

Classes in io.helidon.common.reactive that implement Subscribable

Modifier and Type	Class	Description
class	CompletionSingle<T>	Single as CompletionStage.
final class	ConcatPublisher<T>	Concat streams to one.
class	MultiFromOutputStream	Deprecated, for removal: This API element is subject to removal in a future version. please use OutputStreamMulti instead
final class	MultiTappedPublisher<T>	Intercept the calls to the various Flow interface methods and calls the appropriate user callbacks.
class	OutputStreamMulti	Output stream that Flow.Publisher publishes any data written to it as ByteBuffer events.

Methods in io.helidon.common.reactive that return Subscribable

Modifier and Type	Method	Description
Subscribable<T>	Subscribable.defaultIfEmpty(Supplier<? extends T> supplier)	Signals the default item supplied by specified supplier if the upstream is empty.
Subscribable<T>	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 resulting Flow.Publisher to downstream.
<U> Subscribable<U>	Subscribable.flatMapIterable(Function<? super T,? extends Iterable<? extends U>> mapper)	Transform item with supplied function and flatten resulting Iterable to downstream.
<U> Subscribable<U>	Subscribable.map(Function<? super T,? extends U> mapper)	Map this Subscribable instance to a new Subscribable of another type using the given Function.
Subscribable<T>	Subscribable.observeOn(Executor executor)	Re-emit the upstream's signals to the downstream on the given executor's thread.
Subscribable<T>	Subscribable.onCancel(Runnable onCancel)	Executes given Runnable when a cancel signal is received.
Subscribable<T>	Subscribable.onComplete(Runnable onComplete)	Executes given Runnable when onComplete signal is received.
Subscribable<T>	Subscribable.onCompleteResume(T item)	Resume stream from single item if onComplete signal is intercepted.
Subscribable<T>	Subscribable.onCompleteResumeWith(Flow.Publisher<? extends T> publisher)	Resume stream from supplied publisher if onComplete signal is intercepted.
Subscribable<T>	Subscribable.onError(Consumer<? super Throwable> onErrorConsumer)	Executes given Runnable when onError signal is received.
Subscribable<T>	Subscribable.onErrorResume(Function<? super Throwable,? extends T> onError)	Function providing one item to be submitted as onNext in case of onError signal is received.
Subscribable<T>	Subscribable.onErrorResumeWith(Function<? super Throwable,? extends Flow.Publisher<? extends T>> onError)	Resume stream from supplied publisher if onError signal is intercepted.
Subscribable<T>	Subscribable.onTerminate(Runnable onTerminate)	Executes given Runnable when any of signals onComplete, onCancel or onError is received.
Subscribable<T>	Subscribable.peek(Consumer<? super T> consumer)	Invoke provided consumer for every item in stream.
Subscribable<T>	Subscribable.retry(long count)	Retry a failing upstream at most the given number of times before giving up.
Subscribable<T>	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<T>	Subscribable.timeout(long timeout, TimeUnit unit, ScheduledExecutorService executor)	Signals a TimeoutException if the upstream doesn't signal the next item, error or completion within the specified time.