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

public final Class FlowableInternalHelper

extends Object
Class Inheritance
Imports
java.util.List, java.util.concurrent.*, org.reactivestreams.*, io.reactivex.*, io.reactivex.flowables.ConnectableFlowable, io.reactivex.functions.*, io.reactivex.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.BufferedReplayCallable<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.ReplayCallable<T>

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

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>

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

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> Callable<ConnectableFlowable<T>>
replayCallable(final Flowable<T> parent)

public static <T> Callable<ConnectableFlowable<T>>
replayCallable(final Flowable<T> parent, final int bufferSize)

public static <T> Callable<ConnectableFlowable<T>>
replayCallable(final Flowable<T> parent, final int bufferSize, final long time, final TimeUnit unit, final Scheduler scheduler)

public static <T> Callable<ConnectableFlowable<T>>
replayCallable(final Flowable<T> parent, final long time, final TimeUnit unit, final Scheduler scheduler)

public static <T, R> Function<Flowable<T>, Publisher<R>>
replayFunction(final Function<? super Flowable<T>, ? extends Publisher<R>> selector, final Scheduler scheduler)

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)

public static <T, R> Function<List<Publisher<? extends T>>, Publisher<? extends R>>
zipIterable(final Function<? super Object[], ? extends R> zipper)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait