public final class FlowableInternalHelper extends Object
Modifier and Type | Class and Description |
---|---|
static class |
FlowableInternalHelper.RequestMax |
Modifier and Type | Method and 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> Callable<ConnectableFlowable<T>> |
replayCallable(Flowable<T> parent) |
static <T> Callable<ConnectableFlowable<T>> |
replayCallable(Flowable<T> parent,
int bufferSize) |
static <T> Callable<ConnectableFlowable<T>> |
replayCallable(Flowable<T> parent,
int bufferSize,
long time,
TimeUnit unit,
Scheduler scheduler) |
static <T> Callable<ConnectableFlowable<T>> |
replayCallable(Flowable<T> parent,
long time,
TimeUnit unit,
Scheduler scheduler) |
static <T,R> Function<Flowable<T>,org.reactivestreams.Publisher<R>> |
replayFunction(Function<? super Flowable<T>,? extends org.reactivestreams.Publisher<R>> selector,
Scheduler scheduler) |
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) |
static <T,R> Function<List<org.reactivestreams.Publisher<? extends T>>,org.reactivestreams.Publisher<? extends R>> |
zipIterable(Function<? super Object[],? extends R> zipper) |
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,org.reactivestreams.Publisher<T>> itemDelay(Function<? super T,? extends org.reactivestreams.Publisher<U>> itemDelay)
public static <T> Consumer<T> subscriberOnNext(org.reactivestreams.Subscriber<T> subscriber)
public static <T> Consumer<Throwable> subscriberOnError(org.reactivestreams.Subscriber<T> subscriber)
public static <T> Action subscriberOnComplete(org.reactivestreams.Subscriber<T> subscriber)
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)
public static <T,U> Function<T,org.reactivestreams.Publisher<U>> flatMapIntoIterable(Function<? super T,? extends Iterable<? extends U>> mapper)
public static <T> Callable<ConnectableFlowable<T>> replayCallable(Flowable<T> parent)
public static <T> Callable<ConnectableFlowable<T>> replayCallable(Flowable<T> parent, int bufferSize)
public static <T> Callable<ConnectableFlowable<T>> replayCallable(Flowable<T> parent, int bufferSize, long time, TimeUnit unit, Scheduler scheduler)
public static <T> Callable<ConnectableFlowable<T>> replayCallable(Flowable<T> parent, long time, TimeUnit unit, Scheduler scheduler)
public static <T,R> Function<Flowable<T>,org.reactivestreams.Publisher<R>> replayFunction(Function<? super Flowable<T>,? extends org.reactivestreams.Publisher<R>> selector, Scheduler scheduler)
Copyright © 2019. All rights reserved.