RxJava 3 3.1.8 · io.reactivex.rxjava3.internal.jdk8

Class Summary

Modifier and Type	Class and Description
public class	CompletableFromCompletionStage< the element type of the CompletionsStage T> Wrap a CompletionStage and signal its outcome.
public class	CompletionStageConsumer< the element type T> Class that extends CompletableFuture and converts multiple types of reactive consumers and their signals into completion signals.
public class	FlowableCollectWithCollector< the upstream value type T, the intermediate accumulator type A, the result type R> Collect items into a container defined by a Stream `Collector` callback set.
public class	FlowableCollectWithCollectorSingle< the upstream value type T, the intermediate accumulator type A, the result type R> Collect items into a container defined by a Stream `Collector` callback set.
public class	FlowableFirstStageSubscriber< the element type 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`.
public class	FlowableFlatMapStream< the upstream element type T, the inner `Stream` and result element type R> Maps the upstream values onto `Stream`s and emits their items in order to the downstream.
public class	FlowableFromCompletionStage< the element type T> Wrap a CompletionStage and signal its outcome.
public class	FlowableFromStream< the element type of the Stream T> Wraps a `Stream` and emits its values as a Flowable sequence.
public class	FlowableLastStageSubscriber< the element type 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`.
public class	FlowableMapOptional< the upstream element type T, the output element type R> Map the upstream values into an Optional and emit its value if any.
public class	FlowableSingleStageSubscriber< the element type 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.
pack-priv abstract class	FlowableStageSubscriber< the element type T> Base class that extends CompletableFuture and provides basic infrastructure to notify watchers upon upstream signals.
public class	MaybeFlattenStreamAsFlowable< the source value type T, the output value type R> Map the success value into a Java `Stream` and emits its values.
public class	MaybeFlattenStreamAsObservable< the source value type T, the output value type R> Map the success value into a Java `Stream` and emits its values.
public class	MaybeFromCompletionStage< the element type T> Wrap a CompletionStage and signal its outcome.
public class	MaybeMapOptional< the upstream success value type T, the result value type R> Maps the success value to an `Optional` and emits its non-empty value or completes.
public class	ObservableCollectWithCollector< the upstream value type T, the intermediate accumulator type A, the result type R> Collect items into a container defined by a Stream `Collector` callback set.
public class	ObservableCollectWithCollectorSingle< the upstream value type T, the intermediate accumulator type A, the result type R> Collect items into a container defined by a Stream `Collector` callback set.
public class	ObservableFirstStageObserver< the element type 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`.
public class	ObservableFlatMapStream< the upstream element type T, the inner `Stream` and result element type R> Maps the upstream values onto `Stream`s and emits their items in order to the downstream.
public class	ObservableFromCompletionStage< the element type T> Wrap a CompletionStage and signal its outcome.
public class	ObservableFromStream< the element type of the Stream T> Wraps a `Stream` and emits its values as an `Observable` sequence.
public class	ObservableLastStageObserver< the element type 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`.
public class	ObservableMapOptional< the upstream element type T, the output element type R> Map the upstream values into an Optional and emit its value if any.
public class	ObservableSingleStageObserver< the element type 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.
pack-priv abstract class	ObservableStageObserver< the element type T> Base class that extends CompletableFuture and provides basic infrastructure to notify watchers upon upstream signals.
public class	ParallelCollector< the value type T, the accumulator type A, the result type R> Reduces all 'rails' into a single via a Java 8 `Collector` callback set.
public class	ParallelFlatMapStream< the input value type T, the output value type R> Flattens the generated `Stream`s on each rail.
public class	ParallelMapOptional< the input value type T, the output value type R> Maps each 'rail' of the source ParallelFlowable with a mapper function.
public class	ParallelMapTryOptional< the input value type T, the output value type R> Maps each 'rail' of the source ParallelFlowable with a mapper function and handle any failure based on a handler function.
public class	SingleFlattenStreamAsFlowable< the source value type T, the output value type R> Map the success value into a Java `Stream` and emits its values.
public class	SingleFlattenStreamAsObservable< the source value type T, the output value type R> Map the success value into a Java `Stream` and emits its values.
public class	SingleFromCompletionStage< the element type T> Wrap a CompletionStage and signal its outcome.
public class	SingleMapOptional< the upstream success value type T, the result value type R> Maps the success value to an `Optional` and emits its non-empty value or completes.

Package io.reactivex.rxjava3.internal.jdk8

Class Summary