Class FlowableInternalHelper
- java.lang.Object
-
- io.reactivex.rxjava3.internal.operators.flowable.FlowableInternalHelper
-
public final class FlowableInternalHelper extends java.lang.Object
Helper utility class to support Flowable with inner classes.
-
-
Nested Class Summary
-
Constructor Summary
Constructors Modifier Constructor Description private
FlowableInternalHelper()
Utility class.
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T,U>
Function<T,org.reactivestreams.Publisher<U>>flatMapIntoIterable(Function<? super T,? extends java.lang.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>>itemDelay(Function<? super T,? extends org.reactivestreams.Publisher<U>> itemDelay)
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, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
static <T> Supplier<ConnectableFlowable<T>>
replaySupplier(Flowable<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)
static <T> Action
subscriberOnComplete(org.reactivestreams.Subscriber<T> subscriber)
static <T> Consumer<java.lang.Throwable>
subscriberOnError(org.reactivestreams.Subscriber<T> subscriber)
static <T> Consumer<T>
subscriberOnNext(org.reactivestreams.Subscriber<T> subscriber)
-
-
-
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,org.reactivestreams.Publisher<T>> itemDelay(Function<? super T,? extends org.reactivestreams.Publisher<U>> itemDelay)
-
subscriberOnNext
public static <T> Consumer<T> subscriberOnNext(org.reactivestreams.Subscriber<T> subscriber)
-
subscriberOnError
public static <T> Consumer<java.lang.Throwable> subscriberOnError(org.reactivestreams.Subscriber<T> subscriber)
-
subscriberOnComplete
public static <T> Action subscriberOnComplete(org.reactivestreams.Subscriber<T> subscriber)
-
flatMapWithCombiner
public 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)
-
flatMapIntoIterable
public static <T,U> Function<T,org.reactivestreams.Publisher<U>> flatMapIntoIterable(Function<? super T,? extends java.lang.Iterable<? extends U>> mapper)
-
replaySupplier
public static <T> Supplier<ConnectableFlowable<T>> replaySupplier(Flowable<T> parent)
-
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, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
-
replaySupplier
public static <T> Supplier<ConnectableFlowable<T>> replaySupplier(Flowable<T> parent, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
-
-