Package io.reactivex.rxjava3.internal.jdk8
package io.reactivex.rxjava3.internal.jdk8
-
ClassesClassDescriptionWrap a CompletionStage and signal its outcome.Class that extends CompletableFuture and converts multiple types of reactive consumers and their signals into completion signals.FlowableCollectWithCollector<T,
A, R> Collect items into a container defined by a StreamCollector
callback set.Collect items into a container defined by a StreamCollector
callback set.Signals the first element of the source via the underlying CompletableFuture, signals the a default item if the upstream is empty or signalsNoSuchElementException
.Maps the upstream values ontoStream
s and emits their items in order to the downstream.Wrap a CompletionStage and signal its outcome.Wraps aStream
and emits its values as a Flowable sequence.Signals the last element of the source via the underlying CompletableFuture, signals the a default item if the upstream is empty or signalsNoSuchElementException
.FlowableMapOptional<T,R> Map the upstream values into an Optional and emit its value if any.Signals the only element of the source via the underlying CompletableFuture, signals the a default item if the upstream is empty or signalsIllegalArgumentException
if the upstream has more than one item.Base class that extends CompletableFuture and provides basic infrastructure to notify watchers upon upstream signals.Map the success value into a JavaStream
and emits its values.Map the success value into a JavaStream
and emits its values.Wrap a CompletionStage and signal its outcome.MaybeMapOptional<T,R> Maps the success value to anOptional
and emits its non-empty value or completes.Collect items into a container defined by a StreamCollector
callback set.Collect items into a container defined by a StreamCollector
callback set.Signals the first element of the source via the underlying CompletableFuture, signals the a default item if the upstream is empty or signalsNoSuchElementException
.Maps the upstream values ontoStream
s and emits their items in order to the downstream.Wrap a CompletionStage and signal its outcome.Wraps aStream
and emits its values as anObservable
sequence.Signals the last element of the source via the underlying CompletableFuture, signals the a default item if the upstream is empty or signalsNoSuchElementException
.Map the upstream values into an Optional and emit its value if any.Signals the only element of the source via the underlying CompletableFuture, signals the a default item if the upstream is empty or signalsIllegalArgumentException
if the upstream has more than one item.Base class that extends CompletableFuture and provides basic infrastructure to notify watchers upon upstream signals.ParallelCollector<T,A, R> Reduces all 'rails' into a single via a Java 8Collector
callback set.Flattens the generatedStream
s on each rail.ParallelMapOptional<T,R> Maps each 'rail' of the source ParallelFlowable with a mapper function.Maps each 'rail' of the source ParallelFlowable with a mapper function and handle any failure based on a handler function.Map the success value into a JavaStream
and emits its values.Map the success value into a JavaStream
and emits its values.Wrap a CompletionStage and signal its outcome.SingleMapOptional<T,R> Maps the success value to anOptional
and emits its non-empty value or completes.