Class FlowableInternalHelper
java.lang.Object
io.reactivex.rxjava3.internal.operators.flowable.FlowableInternalHelper
Helper utility class to support Flowable 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 final class
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
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <T,
U> Function <T, org.reactivestreams.Publisher<U>> flatMapIntoIterable
(Function<? super T, ? extends Iterable<? extends U>> mapper) static <T,
U, R> Function <T, org.reactivestreams.Publisher<R>> flatMapWithCombiner
(Function<? super T, ? extends org.reactivestreams.Publisher<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> combiner) static <T,
U> Function <T, org.reactivestreams.Publisher<T>> static <T> Supplier
<ConnectableFlowable<T>> replaySupplier
(Flowable<T> parent) static <T> Supplier
<ConnectableFlowable<T>> replaySupplier
(Flowable<T> parent, int bufferSize, boolean eagerTruncate) static <T> Supplier
<ConnectableFlowable<T>> replaySupplier
(Flowable<T> parent, int bufferSize, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) static <T> Supplier
<ConnectableFlowable<T>> replaySupplier
(Flowable<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) static <T> Action
subscriberOnComplete
(org.reactivestreams.Subscriber<T> subscriber) subscriberOnError
(org.reactivestreams.Subscriber<T> subscriber) static <T> Consumer
<T> subscriberOnNext
(org.reactivestreams.Subscriber<T> subscriber)
-
Constructor Details
-
FlowableInternalHelper
private FlowableInternalHelper()Utility class.
-
-
Method Details
-
simpleGenerator
-
simpleBiGenerator
public static <T,S> BiFunction<S,Emitter<T>, simpleBiGeneratorS> (BiConsumer<S, Emitter<T>> consumer) -
itemDelay
-
subscriberOnNext
-
subscriberOnError
-
subscriberOnComplete
-
flatMapWithCombiner
public static <T,U, Function<T,R> org.reactivestreams.Publisher<R>> flatMapWithCombiner(Function<? super T, ? extends org.reactivestreams.Publisher<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> combiner) -
flatMapIntoIterable
-
replaySupplier
-
replaySupplier
public static <T> Supplier<ConnectableFlowable<T>> replaySupplier(Flowable<T> parent, int bufferSize, boolean eagerTruncate) -
replaySupplier
public static <T> Supplier<ConnectableFlowable<T>> replaySupplier(Flowable<T> parent, int bufferSize, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) -
replaySupplier
public static <T> Supplier<ConnectableFlowable<T>> replaySupplier(Flowable<T> parent, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
-