Class ObservableInternalHelper

java.lang.Object

io.reactivex.rxjava3.internal.operators.observable.ObservableInternalHelper

public final class ObservableInternalHelper
extends Object

Helper utility class to support Observable with inner classes.

Method Summary

Modifier and Type	Method	Description
static <T,U> Function<T, ObservableSource<U>>	flatMapIntoIterable(Function<? super T, ? extends Iterable<? extends U>> mapper)
static <T,U,R> Function<T, ObservableSource<R>>	flatMapWithCombiner(Function<? super T, ? extends ObservableSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> combiner)
static <T,U> Function<T, ObservableSource<T>>	itemDelay(Function<? super T, ? extends ObservableSource<U>> itemDelay)
static <T> Action	observerOnComplete(Observer<T> observer)
static <T> Consumer<Throwable>	observerOnError(Observer<T> observer)
static <T> Consumer<T>	observerOnNext(Observer<T> observer)
static <T> Supplier<ConnectableObservable<T>>	replaySupplier(Observable<T> parent)
static <T> Supplier<ConnectableObservable<T>>	replaySupplier(Observable<T> parent, int bufferSize, boolean eagerTruncate)
static <T> Supplier<ConnectableObservable<T>>	replaySupplier(Observable<T> parent, int bufferSize, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
static <T> Supplier<ConnectableObservable<T>>	replaySupplier(Observable<T> parent, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
static <T,S> BiFunction<S, Emitter<T>, S>	simpleBiGenerator(BiConsumer<S, Emitter<T>> consumer)
static <T,S> BiFunction<S, Emitter<T>, S>	simpleGenerator(Consumer<Emitter<T>> consumer)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

simpleGenerator

public static <T,S> BiFunction<S, Emitter<T>, S> simpleGenerator(Consumer<Emitter<T>> consumer)

simpleBiGenerator

public static <T,S> BiFunction<S, Emitter<T>, S> simpleBiGenerator(BiConsumer<S, Emitter<T>> consumer)

itemDelay

public static <T,U>
Function<T, ObservableSource<T>> itemDelay(Function<? super T, ? extends ObservableSource<U>> itemDelay)

observerOnNext

public static <T> Consumer<T> observerOnNext(Observer<T> observer)

observerOnError

public static <T> Consumer<Throwable> observerOnError(Observer<T> observer)

observerOnComplete

public static <T> Action observerOnComplete(Observer<T> observer)

flatMapWithCombiner

public static <T,U,R>
Function<T, ObservableSource<R>> flatMapWithCombiner(Function<? super T, ? extends ObservableSource<? extends U>> mapper,
 BiFunction<? super T, ? super U, ? extends R> combiner)

flatMapIntoIterable

public static <T,U>
Function<T, ObservableSource<U>> flatMapIntoIterable(Function<? super T, ? extends Iterable<? extends U>> mapper)

replaySupplier

public static <T>
Supplier<ConnectableObservable<T>> replaySupplier(Observable<T> parent)

replaySupplier

public static <T>
Supplier<ConnectableObservable<T>> replaySupplier(Observable<T> parent,
 int bufferSize,
 boolean eagerTruncate)

replaySupplier

public static <T>
Supplier<ConnectableObservable<T>> replaySupplier(Observable<T> parent,
 int bufferSize,
 long time,
 TimeUnit unit,
 Scheduler scheduler,
 boolean eagerTruncate)

replaySupplier

public static <T>
Supplier<ConnectableObservable<T>> replaySupplier(Observable<T> parent,
 long time,
 TimeUnit unit,
 Scheduler scheduler,
 boolean eagerTruncate)