Class ObservableInternalHelper
java.lang.Object
io.reactivex.rxjava3.internal.operators.observable.ObservableInternalHelper
Helper utility class to support Observable with inner classes.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static enum
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <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) 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)
-
Constructor Details
-
ObservableInternalHelper
private ObservableInternalHelper()
-
-
Method Details
-
simpleGenerator
-
simpleBiGenerator
public static <T,S> BiFunction<S,Emitter<T>, simpleBiGeneratorS> (BiConsumer<S, Emitter<T>> consumer) -
itemDelay
public static <T,U> Function<T,ObservableSource<T>> itemDelay(Function<? super T, ? extends ObservableSource<U>> itemDelay) -
observerOnNext
-
observerOnError
-
observerOnComplete
-
flatMapWithCombiner
public static <T,U, Function<T,R> 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
-
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)
-