CompletableFromCompletionStage<T> |
Wrap a CompletionStage and signal its outcome.
|
CompletableFromCompletionStage.CompletionStageHandler<T> |
|
CompletionStageConsumer<T> |
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 Stream Collector callback set.
|
FlowableCollectWithCollector.CollectorSubscriber<T,A,R> |
|
FlowableCollectWithCollectorSingle<T,A,R> |
Collect items into a container defined by a Stream Collector callback set.
|
FlowableCollectWithCollectorSingle.CollectorSingleObserver<T,A,R> |
|
FlowableFirstStageSubscriber<T> |
Signals the first element of the source via the underlying CompletableFuture,
signals the a default item if the upstream is empty or signals NoSuchElementException .
|
FlowableFlatMapStream<T,R> |
Maps the upstream values onto Stream s and emits their items in order to the downstream.
|
FlowableFlatMapStream.FlatMapStreamSubscriber<T,R> |
|
FlowableFromCompletionStage<T> |
Wrap a CompletionStage and signal its outcome.
|
FlowableFromCompletionStage.BiConsumerAtomicReference<T> |
|
FlowableFromCompletionStage.CompletionStageHandler<T> |
|
FlowableFromStream<T> |
Wraps a Stream and emits its values as a Flowable sequence.
|
FlowableFromStream.AbstractStreamSubscription<T> |
|
FlowableFromStream.StreamConditionalSubscription<T> |
|
FlowableFromStream.StreamSubscription<T> |
|
FlowableLastStageSubscriber<T> |
Signals the last element of the source via the underlying CompletableFuture,
signals the a default item if the upstream is empty or signals NoSuchElementException .
|
FlowableMapOptional<T,R> |
Map the upstream values into an Optional and emit its value if any.
|
FlowableMapOptional.MapOptionalConditionalSubscriber<T,R> |
|
FlowableMapOptional.MapOptionalSubscriber<T,R> |
|
FlowableSingleStageSubscriber<T> |
Signals the only element of the source via the underlying CompletableFuture,
signals the a default item if the upstream is empty or signals IllegalArgumentException
if the upstream has more than one item.
|
FlowableStageSubscriber<T> |
Base class that extends CompletableFuture and provides basic infrastructure
to notify watchers upon upstream signals.
|
MaybeFlattenStreamAsFlowable<T,R> |
Map the success value into a Java Stream and emits its values.
|
MaybeFlattenStreamAsFlowable.FlattenStreamMultiObserver<T,R> |
|
MaybeFlattenStreamAsObservable<T,R> |
Map the success value into a Java Stream and emits its values.
|
MaybeFlattenStreamAsObservable.FlattenStreamMultiObserver<T,R> |
|
MaybeFromCompletionStage<T> |
Wrap a CompletionStage and signal its outcome.
|
MaybeFromCompletionStage.CompletionStageHandler<T> |
|
MaybeMapOptional<T,R> |
Maps the success value to an Optional and emits its non-empty value or completes.
|
MaybeMapOptional.MapOptionalMaybeObserver<T,R> |
|
ObservableCollectWithCollector<T,A,R> |
Collect items into a container defined by a Stream Collector callback set.
|
ObservableCollectWithCollector.CollectorObserver<T,A,R> |
|
ObservableCollectWithCollectorSingle<T,A,R> |
Collect items into a container defined by a Stream Collector callback set.
|
ObservableCollectWithCollectorSingle.CollectorSingleObserver<T,A,R> |
|
ObservableFirstStageObserver<T> |
Signals the first element of the source via the underlying CompletableFuture,
signals the a default item if the upstream is empty or signals NoSuchElementException .
|
ObservableFlatMapStream<T,R> |
Maps the upstream values onto Stream s and emits their items in order to the downstream.
|
ObservableFlatMapStream.FlatMapStreamObserver<T,R> |
|
ObservableFromCompletionStage<T> |
Wrap a CompletionStage and signal its outcome.
|
ObservableFromCompletionStage.BiConsumerAtomicReference<T> |
|
ObservableFromCompletionStage.CompletionStageHandler<T> |
|
ObservableFromStream<T> |
Wraps a Stream and emits its values as an Observable sequence.
|
ObservableFromStream.StreamDisposable<T> |
|
ObservableLastStageObserver<T> |
Signals the last element of the source via the underlying CompletableFuture,
signals the a default item if the upstream is empty or signals NoSuchElementException .
|
ObservableMapOptional<T,R> |
Map the upstream values into an Optional and emit its value if any.
|
ObservableMapOptional.MapOptionalObserver<T,R> |
|
ObservableSingleStageObserver<T> |
Signals the only element of the source via the underlying CompletableFuture,
signals the a default item if the upstream is empty or signals IllegalArgumentException
if the upstream has more than one item.
|
ObservableStageObserver<T> |
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 8 Collector callback set.
|
ParallelCollector.ParallelCollectorInnerSubscriber<T,A,R> |
|
ParallelCollector.ParallelCollectorSubscriber<T,A,R> |
|
ParallelCollector.SlotPair<T> |
|
ParallelFlatMapStream<T,R> |
Flattens the generated Stream s on each rail.
|
ParallelMapOptional<T,R> |
Maps each 'rail' of the source ParallelFlowable with a mapper function.
|
ParallelMapOptional.ParallelMapConditionalSubscriber<T,R> |
|
ParallelMapOptional.ParallelMapSubscriber<T,R> |
|
ParallelMapTryOptional<T,R> |
Maps each 'rail' of the source ParallelFlowable with a mapper function
and handle any failure based on a handler function.
|
ParallelMapTryOptional.ParallelMapTryConditionalSubscriber<T,R> |
|
ParallelMapTryOptional.ParallelMapTrySubscriber<T,R> |
|
SingleFlattenStreamAsFlowable<T,R> |
Map the success value into a Java Stream and emits its values.
|
SingleFlattenStreamAsObservable<T,R> |
Map the success value into a Java Stream and emits its values.
|
SingleFromCompletionStage<T> |
Wrap a CompletionStage and signal its outcome.
|
SingleFromCompletionStage.CompletionStageHandler<T> |
|
SingleMapOptional<T,R> |
Maps the success value to an Optional and emits its non-empty value or completes.
|
SingleMapOptional.MapOptionalSingleObserver<T,R> |
|