public final class ObservableInternalHelper extends Object
public static <T,S> BiFunction<S,Emitter<T>,S> simpleGenerator(Consumer<Emitter<T>> consumer)
public static <T,S> BiFunction<S,Emitter<T>,S> simpleBiGenerator(BiConsumer<S,Emitter<T>> consumer)
public static <T,U> Function<T,ObservableSource<T>> itemDelay(Function<? super T,? extends ObservableSource<U>> itemDelay)
public static <T,U,R> Function<T,ObservableSource<R>> flatMapWithCombiner(Function<? super T,? extends ObservableSource<? extends U>> mapper, BiFunction<? super T,? super U,? extends R> combiner)
public static <T,U> Function<T,ObservableSource<U>> flatMapIntoIterable(Function<? super T,? extends Iterable<? extends U>> mapper)
public static <T> Callable<ConnectableObservable<T>> replayCallable(Observable<T> parent)
public static <T> Callable<ConnectableObservable<T>> replayCallable(Observable<T> parent, int bufferSize)
public static <T> Callable<ConnectableObservable<T>> replayCallable(Observable<T> parent, int bufferSize, long time, TimeUnit unit, Scheduler scheduler)
public static <T> Callable<ConnectableObservable<T>> replayCallable(Observable<T> parent, long time, TimeUnit unit, Scheduler scheduler)
public static <T,R> Function<Observable<T>,ObservableSource<R>> replayFunction(Function<? super Observable<T>,? extends ObservableSource<R>> selector, Scheduler scheduler)
public static <T,R> Function<List<ObservableSource<? extends T>>,ObservableSource<? extends R>> zipIterable(Function<? super Object[],? extends R> zipper)
Copyright © 2018 JBoss by Red Hat. All rights reserved.