Top Description Inners Constructors Methods
io.reactivex.rxjava3.internal.operators.flowable

public final Class FlowableInternalHelper

extends Object
Class Inheritance
Imports
java.util.Objects, java.util.concurrent.TimeUnit, org.reactivestreams.*, io.reactivex.rxjava3.core.*, io.reactivex.rxjava3.flowables.ConnectableFlowable, io.reactivex.rxjava3.functions.*, io.reactivex.rxjava3.internal.functions.*
Helper utility class to support Flowable with inner classes.

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
FlowableInternalHelper.BufferedReplaySupplier<T>

pack-priv static class
FlowableInternalHelper.BufferedTimedReplay<T>

pack-priv static class
FlowableInternalHelper.FlatMapIntoIterable<T, U>

pack-priv static class
FlowableInternalHelper.FlatMapWithCombinerInner<U, R, T>

pack-priv static class
FlowableInternalHelper.FlatMapWithCombinerOuter<T, R, U>

pack-priv static class
FlowableInternalHelper.ItemDelayFunction<T, U>

pack-priv static class
FlowableInternalHelper.ReplaySupplier<T>

public static enum
FlowableInternalHelper.RequestMax

pack-priv static class
FlowableInternalHelper.SimpleBiGenerator<T, S>

pack-priv static class
FlowableInternalHelper.SimpleGenerator<T, S>

pack-priv static class
FlowableInternalHelper.SubscriberOnComplete<T>

pack-priv static class
FlowableInternalHelper.SubscriberOnError<T>

pack-priv static class
FlowableInternalHelper.SubscriberOnNext<T>

pack-priv static class
FlowableInternalHelper.TimedReplay<T>

Constructor Summary

AccessConstructor and Description
private
FlowableInternalHelper()

Utility class.

Method Summary

Modifier and TypeMethod and Description
public static <T, U> Function<T, Publisher<U>>
flatMapIntoIterable(final Function<? super T, ? extends Iterable<? extends U>> mapper)

public static <T, U, R> Function<T, Publisher<R>>
flatMapWithCombiner(final Function<? super T, ? extends Publisher<? extends U>> mapper, final BiFunction<? super T, ? super U, ? extends R> combiner)

public static <T, U> Function<T, Publisher<T>>
itemDelay(final Function<? super T, ? extends Publisher<U>> itemDelay)

public static <T> Supplier<ConnectableFlowable<T>>
replaySupplier(final Flowable<T> parent)

public static <T> Supplier<ConnectableFlowable<T>>
replaySupplier(final Flowable<T> parent, final int bufferSize, boolean eagerTruncate)

public static <T> Supplier<ConnectableFlowable<T>>
replaySupplier(final Flowable<T> parent, final int bufferSize, final long time, final TimeUnit unit, final Scheduler scheduler, boolean eagerTruncate)

public static <T> Supplier<ConnectableFlowable<T>>
replaySupplier(final Flowable<T> parent, final long time, final TimeUnit unit, final Scheduler scheduler, boolean eagerTruncate)

public static <T, S> BiFunction<S, Emitter<T>, S>
simpleBiGenerator(BiConsumer<S, Emitter<T>> consumer)

public static <T, S> BiFunction<S, Emitter<T>, S>
simpleGenerator(Consumer<Emitter<T>> consumer)

public static <T> Action
subscriberOnComplete(Subscriber<T> subscriber)

public static <T> Consumer<Throwable>
subscriberOnError(Subscriber<T> subscriber)

public static <T> Consumer<T>
subscriberOnNext(Subscriber<T> subscriber)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait