Class FlowableInternalHelper

java.lang.Object

io.reactivex.rxjava3.internal.operators.flowable.FlowableInternalHelper

public final class FlowableInternalHelper
extends Object

Helper utility class to support Flowable with inner classes.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	FlowableInternalHelper.RequestMax

Method Summary

Modifier and Type	Method	Description
static <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>>	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, 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)
static <T> Consumer<Throwable>	subscriberOnError(org.reactivestreams.Subscriber<T> subscriber)
static <T> Consumer<T>	subscriberOnNext(org.reactivestreams.Subscriber<T> subscriber)

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, 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<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 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,
 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)