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

public final Class ObservableInternalHelper

extends Object
Class Inheritance
Imports
java.util.List, java.util.concurrent.*, io.reactivex.*, io.reactivex.functions.*, io.reactivex.internal.functions.*, io.reactivex.observables.ConnectableObservable
Helper utility class to support Observable with inner classes.

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
ObservableInternalHelper.BufferedReplayCallable<T>

pack-priv static class
ObservableInternalHelper.BufferedTimedReplayCallable<T>

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

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

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

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

pack-priv static enum
ObservableInternalHelper.MapToInt

pack-priv static class
ObservableInternalHelper.ObserverOnComplete<T>

pack-priv static class
ObservableInternalHelper.ObserverOnError<T>

pack-priv static class
ObservableInternalHelper.ObserverOnNext<T>

pack-priv static class
ObservableInternalHelper.ReplayCallable<T>

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

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

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

pack-priv static class
ObservableInternalHelper.TimedReplayCallable<T>

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

Constructor Summary

AccessConstructor and Description
private
ObservableInternalHelper()

Method Summary

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

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

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

public static <T> Action
observerOnComplete(Observer<T> observer)

public static <T> Consumer<Throwable>
observerOnError(Observer<T> observer)

public static <T> Consumer<T>
observerOnNext(Observer<T> observer)

public static <T> Callable<ConnectableObservable<T>>
replayCallable(final Observable<T> parent)

public static <T> Callable<ConnectableObservable<T>>
replayCallable(final Observable<T> parent, final int bufferSize)

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

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

public static <T, R> Function<Observable<T>, ObservableSource<R>>
replayFunction(final Function<? super Observable<T>, ? extends ObservableSource<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, R> Function<List<ObservableSource<? extends T>>, ObservableSource<? extends R>>
zipIterable(final Function<? super Object[], ? extends R> zipper)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait