Class ObservableInternalHelper
- java.lang.Object
-
- io.reactivex.rxjava3.internal.operators.observable.ObservableInternalHelper
-
public final class ObservableInternalHelper extends java.lang.Object
Helper utility class to support Observable with inner classes.
-
-
Nested Class Summary
-
Constructor Summary
Constructors Modifier Constructor Description private
ObservableInternalHelper()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T,U>
Function<T,ObservableSource<U>>flatMapIntoIterable(Function<? super T,? extends java.lang.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<java.lang.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, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
static <T> Supplier<ConnectableObservable<T>>
replaySupplier(Observable<T> parent, long time, java.util.concurrent.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)
-
-
-
Method Detail
-
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)
-
observerOnError
public static <T> Consumer<java.lang.Throwable> observerOnError(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 java.lang.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, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
-
replaySupplier
public static <T> Supplier<ConnectableObservable<T>> replaySupplier(Observable<T> parent, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
-
-