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) |
|
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.
|