Package io.reactivex.rxjava3.internal.jdk8

Class Summary

Class	Description
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 Streams 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 Streams 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 Streams 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>