hu.akarnokd.rxjava2.async

Class AsyncFlowable

java.lang.Object

hu.akarnokd.rxjava2.async.AsyncFlowable

public final class AsyncFlowable
extends java.lang.Object

Utility methods to convert functions and actions into asynchronous operations through the Publisher/Subscriber pattern.

Method Summary

Modifier and Type	Method and Description
static <T> io.reactivex.Flowable<T>	deferFuture(java.util.concurrent.Callable<? extends java.util.concurrent.Future<? extends org.reactivestreams.Publisher<? extends T>>> observableFactoryAsync) Returns an Observable that starts the specified asynchronous factory function whenever a new observer subscribes.
static <T> io.reactivex.Flowable<T>	deferFuture(java.util.concurrent.Callable<? extends java.util.concurrent.Future<? extends org.reactivestreams.Publisher<? extends T>>> observableFactoryAsync, io.reactivex.Scheduler scheduler) Returns an Observable that starts the specified asynchronous factory function whenever a new observer subscribes.
static <T> java.util.concurrent.FutureTask<java.lang.Void>	forEachFuture(org.reactivestreams.Publisher<? extends T> source, io.reactivex.functions.Consumer<? super T> onNext) Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future.
static <T> java.util.concurrent.FutureTask<java.lang.Void>	forEachFuture(org.reactivestreams.Publisher<? extends T> source, io.reactivex.functions.Consumer<? super T> onNext, io.reactivex.functions.Consumer<? super java.lang.Throwable> onError) Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future.
static <T> java.util.concurrent.FutureTask<java.lang.Void>	forEachFuture(org.reactivestreams.Publisher<? extends T> source, io.reactivex.functions.Consumer<? super T> onNext, io.reactivex.functions.Consumer<? super java.lang.Throwable> onError, io.reactivex.functions.Action onCompleted) Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future.
static <T> java.util.concurrent.FutureTask<java.lang.Void>	forEachFuture(org.reactivestreams.Publisher<? extends T> source, io.reactivex.functions.Consumer<? super T> onNext, io.reactivex.functions.Consumer<? super java.lang.Throwable> onError, io.reactivex.functions.Action onCompleted, io.reactivex.Scheduler scheduler) Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future, scheduled on the given Scheduler.
static <T> java.util.concurrent.FutureTask<java.lang.Void>	forEachFuture(org.reactivestreams.Publisher<? extends T> source, io.reactivex.functions.Consumer<? super T> onNext, io.reactivex.functions.Consumer<? super java.lang.Throwable> onError, io.reactivex.Scheduler scheduler) Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future, scheduled on the given Scheduler.
static <T> java.util.concurrent.FutureTask<java.lang.Void>	forEachFuture(org.reactivestreams.Publisher<? extends T> source, io.reactivex.functions.Consumer<? super T> onNext, io.reactivex.Scheduler scheduler) Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future, scheduled on the given scheduler.
static <T> DisposableFlowable<T>	runAsync(io.reactivex.Scheduler scheduler, io.reactivex.functions.BiConsumer<? super org.reactivestreams.Subscriber<? super T>,? super org.reactivestreams.Subscription> action) Runs the provided action on the given scheduler and allows propagation of multiple events to the observers of the returned StoppableObservable.
static <T,U> DisposableFlowable<U>	runAsync(io.reactivex.Scheduler scheduler, org.reactivestreams.Processor<T,U> processor, io.reactivex.functions.BiConsumer<? super org.reactivestreams.Subscriber<? super T>,? super org.reactivestreams.Subscription> action) Runs the provided action on the given scheduler and allows propagation of multiple events to the observers of the returned StoppableObservable.
static <T> io.reactivex.Flowable<T>	start(java.util.concurrent.Callable<? extends T> func) Invokes the specified function asynchronously and returns an Flowable that emits the result.
static <T> io.reactivex.Flowable<T>	start(java.util.concurrent.Callable<T> func, io.reactivex.Scheduler scheduler) Invokes the specified function asynchronously on the specified Scheduler and returns an Flowable that emits the result.
static <T> io.reactivex.Flowable<T>	startFuture(java.util.concurrent.Callable<? extends java.util.concurrent.Future<? extends T>> functionAsync) Invokes the asynchronous function immediately, surfacing the result through an Observable.
static <T> io.reactivex.Flowable<T>	startFuture(java.util.concurrent.Callable<? extends java.util.concurrent.Future<? extends T>> functionAsync, io.reactivex.Scheduler scheduler) Invokes the asynchronous function immediately, surfacing the result through an Observable and waits on the specified Scheduler.
static java.util.concurrent.Callable<io.reactivex.Flowable<java.lang.Object>>	toAsync(io.reactivex.functions.Action action) Convert a synchronous action call into an asynchronous function call through a Flowable.
static java.util.concurrent.Callable<io.reactivex.Flowable<java.lang.Object>>	toAsync(io.reactivex.functions.Action action, io.reactivex.Scheduler scheduler) Convert a synchronous action call into an asynchronous function call through a Flowable.
static <T1,T2> io.reactivex.functions.BiFunction<T1,T2,io.reactivex.Flowable<java.lang.Object>>	toAsync(io.reactivex.functions.BiConsumer<? super T1,? super T2> action) Convert a synchronous action call into an asynchronous function call through a Flowable.
static <T1,T2> io.reactivex.functions.BiFunction<T1,T2,io.reactivex.Flowable<java.lang.Object>>	toAsync(io.reactivex.functions.BiConsumer<? super T1,? super T2> action, io.reactivex.Scheduler scheduler) Convert a synchronous action call into an asynchronous function call through a Flowable.
static <T1,T2,R> io.reactivex.functions.BiFunction<T1,T2,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.BiFunction<? super T1,? super T2,? extends R> func) Convert a synchronous function call into an asynchronous function call through a Flowable.
static <T1,T2,R> io.reactivex.functions.BiFunction<T1,T2,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.BiFunction<? super T1,? super T2,? extends R> func, io.reactivex.Scheduler scheduler) Convert a synchronous function call into an asynchronous function call through a Flowable.
static <R> java.util.concurrent.Callable<io.reactivex.Flowable<R>>	toAsync(java.util.concurrent.Callable<? extends R> func) Convert a synchronous function call into an asynchronous function call through a Flowable.
static <R> java.util.concurrent.Callable<io.reactivex.Flowable<R>>	toAsync(java.util.concurrent.Callable<? extends R> func, io.reactivex.Scheduler scheduler) Convert a synchronous function call into an asynchronous function call through a Flowable.
static <T1> io.reactivex.functions.Function<T1,io.reactivex.Flowable<java.lang.Object>>	toAsync(io.reactivex.functions.Consumer<? super T1> action) Convert a synchronous action call into an asynchronous function call through a Flowable.
static <T1> io.reactivex.functions.Function<T1,io.reactivex.Flowable<java.lang.Object>>	toAsync(io.reactivex.functions.Consumer<? super T1> action, io.reactivex.Scheduler scheduler) Convert a synchronous action call into an asynchronous function call through a Flowable.
static <T1,T2,T3> io.reactivex.functions.Function3<T1,T2,T3,io.reactivex.Flowable<java.lang.Object>>	toAsync(Consumer3<? super T1,? super T2,? super T3> action) Convert a synchronous action call into an asynchronous function call through an Flowable.
static <T1,T2,T3> io.reactivex.functions.Function3<T1,T2,T3,io.reactivex.Flowable<java.lang.Object>>	toAsync(Consumer3<? super T1,? super T2,? super T3> action, io.reactivex.Scheduler scheduler) Convert a synchronous action call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4> io.reactivex.functions.Function4<T1,T2,T3,T4,io.reactivex.Flowable<java.lang.Object>>	toAsync(Consumer4<? super T1,? super T2,? super T3,? super T4> action) Convert a synchronous action call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4> io.reactivex.functions.Function4<T1,T2,T3,T4,io.reactivex.Flowable<java.lang.Object>>	toAsync(Consumer4<? super T1,? super T2,? super T3,? super T4> action, io.reactivex.Scheduler scheduler) Convert a synchronous action call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5> io.reactivex.functions.Function5<T1,T2,T3,T4,T5,io.reactivex.Flowable<java.lang.Void>>	toAsync(Consumer5<? super T1,? super T2,? super T3,? super T4,? super T5> action) Convert a synchronous action call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5> io.reactivex.functions.Function5<T1,T2,T3,T4,T5,io.reactivex.Flowable<java.lang.Void>>	toAsync(Consumer5<? super T1,? super T2,? super T3,? super T4,? super T5> action, io.reactivex.Scheduler scheduler) Convert a synchronous action call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,T6> io.reactivex.functions.Function6<T1,T2,T3,T4,T5,T6,io.reactivex.Flowable<java.lang.Void>>	toAsync(Consumer6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6> action) Convert a synchronous action call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,T6> io.reactivex.functions.Function6<T1,T2,T3,T4,T5,T6,io.reactivex.Flowable<java.lang.Void>>	toAsync(Consumer6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6> action, io.reactivex.Scheduler scheduler) Convert a synchronous action call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,T6,T7> io.reactivex.functions.Function7<T1,T2,T3,T4,T5,T6,T7,io.reactivex.Flowable<java.lang.Void>>	toAsync(Consumer7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7> action) Convert a synchronous action call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,T6,T7> io.reactivex.functions.Function7<T1,T2,T3,T4,T5,T6,T7,io.reactivex.Flowable<java.lang.Void>>	toAsync(Consumer7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7> action, io.reactivex.Scheduler scheduler) Convert a synchronous action call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,T6,T7,T8> io.reactivex.functions.Function8<T1,T2,T3,T4,T5,T6,T7,T8,io.reactivex.Flowable<java.lang.Void>>	toAsync(Consumer8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8> action) Convert a synchronous action call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,T6,T7,T8> io.reactivex.functions.Function8<T1,T2,T3,T4,T5,T6,T7,T8,io.reactivex.Flowable<java.lang.Void>>	toAsync(Consumer8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8> action, io.reactivex.Scheduler scheduler) Convert a synchronous action call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,T6,T7,T8,T9> io.reactivex.functions.Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,io.reactivex.Flowable<java.lang.Void>>	toAsync(Consumer9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9> action) Convert a synchronous action call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,T6,T7,T8,T9> io.reactivex.functions.Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,io.reactivex.Flowable<java.lang.Void>>	toAsync(Consumer9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9> action, io.reactivex.Scheduler scheduler) Convert a synchronous action call into an asynchronous function call through an Flowable.
static <T1,R> io.reactivex.functions.Function<T1,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.Function<? super T1,? extends R> func) Convert a synchronous function call into an asynchronous function call through a Flowable.
static <T1,R> io.reactivex.functions.Function<T1,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.Function<? super T1,? extends R> func, io.reactivex.Scheduler scheduler) Convert a synchronous function call into an asynchronous function call through a Flowable.
static <T1,T2,T3,R> io.reactivex.functions.Function3<T1,T2,T3,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.Function3<? super T1,? super T2,? super T3,? extends R> func) Convert a synchronous function call into an asynchronous function call through an Flowable.
static <T1,T2,T3,R> io.reactivex.functions.Function3<T1,T2,T3,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.Function3<? super T1,? super T2,? super T3,? extends R> func, io.reactivex.Scheduler scheduler) Convert a synchronous function call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,R> io.reactivex.functions.Function4<T1,T2,T3,T4,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.Function4<? super T1,? super T2,? super T3,? super T4,? extends R> func) Convert a synchronous function call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,R> io.reactivex.functions.Function4<T1,T2,T3,T4,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.Function4<? super T1,? super T2,? super T3,? super T4,? extends R> func, io.reactivex.Scheduler scheduler) Convert a synchronous function call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,R> io.reactivex.functions.Function5<T1,T2,T3,T4,T5,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> func) Convert a synchronous function call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,R> io.reactivex.functions.Function5<T1,T2,T3,T4,T5,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> func, io.reactivex.Scheduler scheduler) Convert a synchronous function call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,T6,R> io.reactivex.functions.Function6<T1,T2,T3,T4,T5,T6,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> func) Convert a synchronous function call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,T6,R> io.reactivex.functions.Function6<T1,T2,T3,T4,T5,T6,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> func, io.reactivex.Scheduler scheduler) Convert a synchronous function call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,T6,T7,R> io.reactivex.functions.Function7<T1,T2,T3,T4,T5,T6,T7,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> func) Convert a synchronous function call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,T6,T7,R> io.reactivex.functions.Function7<T1,T2,T3,T4,T5,T6,T7,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> func, io.reactivex.Scheduler scheduler) Convert a synchronous function call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,T6,T7,T8,R> io.reactivex.functions.Function8<T1,T2,T3,T4,T5,T6,T7,T8,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> func) Convert a synchronous function call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,T6,T7,T8,R> io.reactivex.functions.Function8<T1,T2,T3,T4,T5,T6,T7,T8,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> func, io.reactivex.Scheduler scheduler) Convert a synchronous function call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> io.reactivex.functions.Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> func) Convert a synchronous function call into an asynchronous function call through an Flowable.
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> io.reactivex.functions.Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,io.reactivex.Flowable<R>>	toAsync(io.reactivex.functions.Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> func, io.reactivex.Scheduler scheduler) Convert a synchronous function call into an asynchronous function call through an Flowable.
static io.reactivex.functions.Function<java.lang.Object[],io.reactivex.Flowable<java.lang.Void>>	toAsyncArray(io.reactivex.functions.Consumer<? super java.lang.Object[]> action) Convert a synchronous action call into an asynchronous function call through an Flowable.
static io.reactivex.functions.Function<java.lang.Object[],io.reactivex.Flowable<java.lang.Void>>	toAsyncArray(io.reactivex.functions.Consumer<? super java.lang.Object[]> action, io.reactivex.Scheduler scheduler) Convert a synchronous action call into an asynchronous function call through an Flowable.
static <R> io.reactivex.functions.Function<java.lang.Object[],io.reactivex.Flowable<R>>	toAsyncArray(io.reactivex.functions.Function<? super java.lang.Object[],? extends R> func) Convert a synchronous function call into an asynchronous function call through an Flowable.
static <R> io.reactivex.functions.Function<java.lang.Object[],io.reactivex.Flowable<R>>	toAsyncArray(io.reactivex.functions.Function<? super java.lang.Object[],? extends R> func, io.reactivex.Scheduler scheduler) Convert a synchronous function call into an asynchronous function call through an Flowable.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

start

public static <T> io.reactivex.Flowable<T> start(java.util.concurrent.Callable<? extends T> func)

Invokes the specified function asynchronously and returns an Flowable that emits the result.

Note: The function is called immediately and once, not whenever an observer subscribes to the resulting Flowable. Multiple subscriptions to this Flowable observe the same return value.

Type Parameters:

T - the result value type

Parameters:

func - function to run asynchronously

Returns:

an Flowable that emits the function's result value, or notifies observers of an exception

See Also:

RxJava Wiki: start(), MSDN: Observable.Start

start

public static <T> io.reactivex.Flowable<T> start(java.util.concurrent.Callable<T> func,
                                                 io.reactivex.Scheduler scheduler)

Invokes the specified function asynchronously on the specified Scheduler and returns an Flowable that emits the result.

Note: The function is called immediately and once, not whenever an observer subscribes to the resulting Flowable. Multiple subscriptions to this Flowable observe the same return value.

Type Parameters:

T - the result value type

Parameters:

func - function to run asynchronously

scheduler - Scheduler to run the function on

Returns:

an Flowable that emits the function's result value, or notifies observers of an exception

See Also:

RxJava Wiki: start(), MSDN: Observable.Start

toAsync

public static java.util.concurrent.Callable<io.reactivex.Flowable<java.lang.Object>> toAsync(io.reactivex.functions.Action action)

Convert a synchronous action call into an asynchronous function call through a Flowable.

Parameters:

action - the action to convert

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <R> java.util.concurrent.Callable<io.reactivex.Flowable<R>> toAsync(java.util.concurrent.Callable<? extends R> func)

Convert a synchronous function call into an asynchronous function call through a Flowable.

Type Parameters:

R - the result value type

Parameters:

func - the function to convert

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1> io.reactivex.functions.Function<T1,io.reactivex.Flowable<java.lang.Object>> toAsync(io.reactivex.functions.Consumer<? super T1> action)

Convert a synchronous action call into an asynchronous function call through a Flowable.

Type Parameters:

T1 - first parameter type of the action

Parameters:

action - the action to convert

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,R> io.reactivex.functions.Function<T1,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.Function<? super T1,? extends R> func)

Convert a synchronous function call into an asynchronous function call through a Flowable.

Type Parameters:

T1 - first parameter type of the action

R - the result type

Parameters:

func - the function to convert

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2> io.reactivex.functions.BiFunction<T1,T2,io.reactivex.Flowable<java.lang.Object>> toAsync(io.reactivex.functions.BiConsumer<? super T1,? super T2> action)

Convert a synchronous action call into an asynchronous function call through a Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

Parameters:

action - the action to convert

Returns:

a function that returns a Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,R> io.reactivex.functions.BiFunction<T1,T2,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.BiFunction<? super T1,? super T2,? extends R> func)

Convert a synchronous function call into an asynchronous function call through a Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

R - the result type

Parameters:

func - the function to convert

Returns:

a function that returns a Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3> io.reactivex.functions.Function3<T1,T2,T3,io.reactivex.Flowable<java.lang.Object>> toAsync(Consumer3<? super T1,? super T2,? super T3> action)

Convert a synchronous action call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

Parameters:

action - the action to convert

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,R> io.reactivex.functions.Function3<T1,T2,T3,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.Function3<? super T1,? super T2,? super T3,? extends R> func)

Convert a synchronous function call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

R - the result type

Parameters:

func - the function to convert

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4> io.reactivex.functions.Function4<T1,T2,T3,T4,io.reactivex.Flowable<java.lang.Object>> toAsync(Consumer4<? super T1,? super T2,? super T3,? super T4> action)

Convert a synchronous action call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

Parameters:

action - the action to convert

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,R> io.reactivex.functions.Function4<T1,T2,T3,T4,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.Function4<? super T1,? super T2,? super T3,? super T4,? extends R> func)

Convert a synchronous function call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

R - the result type

Parameters:

func - the function to convert

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5> io.reactivex.functions.Function5<T1,T2,T3,T4,T5,io.reactivex.Flowable<java.lang.Void>> toAsync(Consumer5<? super T1,? super T2,? super T3,? super T4,? super T5> action)

Convert a synchronous action call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

Parameters:

action - the action to convert

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,R> io.reactivex.functions.Function5<T1,T2,T3,T4,T5,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> func)

Convert a synchronous function call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

R - the result type

Parameters:

func - the function to convert

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,T6> io.reactivex.functions.Function6<T1,T2,T3,T4,T5,T6,io.reactivex.Flowable<java.lang.Void>> toAsync(Consumer6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6> action)

Convert a synchronous action call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

T6 - the sixth parameter type

Parameters:

action - the action to convert

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,T6,R> io.reactivex.functions.Function6<T1,T2,T3,T4,T5,T6,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> func)

Convert a synchronous function call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

T6 - the sixth parameter type

R - the result type

Parameters:

func - the function to convert

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,T6,T7> io.reactivex.functions.Function7<T1,T2,T3,T4,T5,T6,T7,io.reactivex.Flowable<java.lang.Void>> toAsync(Consumer7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7> action)

Convert a synchronous action call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

T6 - the sixth parameter type

T7 - the seventh parameter type

Parameters:

action - the action to convert

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,T6,T7,R> io.reactivex.functions.Function7<T1,T2,T3,T4,T5,T6,T7,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> func)

Convert a synchronous function call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

T6 - the sixth parameter type

T7 - the seventh parameter type

R - the result type

Parameters:

func - the function to convert

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,T6,T7,T8> io.reactivex.functions.Function8<T1,T2,T3,T4,T5,T6,T7,T8,io.reactivex.Flowable<java.lang.Void>> toAsync(Consumer8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8> action)

Convert a synchronous action call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

T6 - the sixth parameter type

T7 - the seventh parameter type

T8 - the eighth parameter type

Parameters:

action - the action to convert

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,T6,T7,T8,R> io.reactivex.functions.Function8<T1,T2,T3,T4,T5,T6,T7,T8,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> func)

Convert a synchronous function call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

T6 - the sixth parameter type

T7 - the seventh parameter type

T8 - the eighth parameter type

R - the result type

Parameters:

func - the function to convert

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,T6,T7,T8,T9> io.reactivex.functions.Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,io.reactivex.Flowable<java.lang.Void>> toAsync(Consumer9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9> action)

Convert a synchronous action call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

T6 - the sixth parameter type

T7 - the seventh parameter type

T8 - the eighth parameter type

T9 - the ninth parameter type

Parameters:

action - the action to convert

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> io.reactivex.functions.Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> func)

Convert a synchronous function call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

T6 - the sixth parameter type

T7 - the seventh parameter type

T8 - the eighth parameter type

T9 - the ninth parameter type

R - the result type

Parameters:

func - the function to convert

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsyncArray

public static io.reactivex.functions.Function<java.lang.Object[],io.reactivex.Flowable<java.lang.Void>> toAsyncArray(io.reactivex.functions.Consumer<? super java.lang.Object[]> action)

Convert a synchronous action call into an asynchronous function call through an Flowable.

Parameters:

action - the action to convert

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync()

toAsyncArray

public static <R> io.reactivex.functions.Function<java.lang.Object[],io.reactivex.Flowable<R>> toAsyncArray(io.reactivex.functions.Function<? super java.lang.Object[],? extends R> func)

Convert a synchronous function call into an asynchronous function call through an Flowable.

Type Parameters:

R - the result type

Parameters:

func - the function to convert

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync()

toAsync

public static java.util.concurrent.Callable<io.reactivex.Flowable<java.lang.Object>> toAsync(io.reactivex.functions.Action action,
                                                                                             io.reactivex.Scheduler scheduler)

Convert a synchronous action call into an asynchronous function call through a Flowable.

Parameters:

action - the action to convert

scheduler - the Scheduler used to execute the action

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <R> java.util.concurrent.Callable<io.reactivex.Flowable<R>> toAsync(java.util.concurrent.Callable<? extends R> func,
                                                                                  io.reactivex.Scheduler scheduler)

Convert a synchronous function call into an asynchronous function call through a Flowable.

Type Parameters:

R - the result value type

Parameters:

func - the function to convert

scheduler - the Scheduler used to call the func

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1> io.reactivex.functions.Function<T1,io.reactivex.Flowable<java.lang.Object>> toAsync(io.reactivex.functions.Consumer<? super T1> action,
                                                                                                       io.reactivex.Scheduler scheduler)

Convert a synchronous action call into an asynchronous function call through a Flowable.

Type Parameters:

T1 - first parameter type of the action

Parameters:

action - the action to convert

scheduler - the Scheduler used to execute the action

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,R> io.reactivex.functions.Function<T1,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.Function<? super T1,? extends R> func,
                                                                                          io.reactivex.Scheduler scheduler)

Convert a synchronous function call into an asynchronous function call through a Flowable.

Type Parameters:

T1 - first parameter type of the action

R - the result type

Parameters:

func - the function to convert

scheduler - the Scheduler used to call the func

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2> io.reactivex.functions.BiFunction<T1,T2,io.reactivex.Flowable<java.lang.Object>> toAsync(io.reactivex.functions.BiConsumer<? super T1,? super T2> action,
                                                                                                               io.reactivex.Scheduler scheduler)

Convert a synchronous action call into an asynchronous function call through a Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

Parameters:

action - the action to convert

scheduler - the Scheduler used to execute the action

Returns:

a function that returns a Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,R> io.reactivex.functions.BiFunction<T1,T2,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.BiFunction<? super T1,? super T2,? extends R> func,
                                                                                                  io.reactivex.Scheduler scheduler)

Convert a synchronous function call into an asynchronous function call through a Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

R - the result type

Parameters:

func - the function to convert

scheduler - the Scheduler used to call the func

Returns:

a function that returns a Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3> io.reactivex.functions.Function3<T1,T2,T3,io.reactivex.Flowable<java.lang.Object>> toAsync(Consumer3<? super T1,? super T2,? super T3> action,
                                                                                                                    io.reactivex.Scheduler scheduler)

Convert a synchronous action call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

Parameters:

action - the action to convert

scheduler - the Scheduler used to execute the action

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,R> io.reactivex.functions.Function3<T1,T2,T3,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.Function3<? super T1,? super T2,? super T3,? extends R> func,
                                                                                                       io.reactivex.Scheduler scheduler)

Convert a synchronous function call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

R - the result type

Parameters:

func - the function to convert

scheduler - the Scheduler used to call the func

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4> io.reactivex.functions.Function4<T1,T2,T3,T4,io.reactivex.Flowable<java.lang.Object>> toAsync(Consumer4<? super T1,? super T2,? super T3,? super T4> action,
                                                                                                                          io.reactivex.Scheduler scheduler)

Convert a synchronous action call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

Parameters:

action - the action to convert

scheduler - the Scheduler used to execute the action

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,R> io.reactivex.functions.Function4<T1,T2,T3,T4,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.Function4<? super T1,? super T2,? super T3,? super T4,? extends R> func,
                                                                                                             io.reactivex.Scheduler scheduler)

Convert a synchronous function call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

R - the result type

Parameters:

func - the function to convert

scheduler - the Scheduler used to call the func

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5> io.reactivex.functions.Function5<T1,T2,T3,T4,T5,io.reactivex.Flowable<java.lang.Void>> toAsync(Consumer5<? super T1,? super T2,? super T3,? super T4,? super T5> action,
                                                                                                                              io.reactivex.Scheduler scheduler)

Convert a synchronous action call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

Parameters:

action - the action to convert

scheduler - the Scheduler used to execute the action

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,R> io.reactivex.functions.Function5<T1,T2,T3,T4,T5,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> func,
                                                                                                                   io.reactivex.Scheduler scheduler)

Convert a synchronous function call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

R - the result type

Parameters:

func - the function to convert

scheduler - the Scheduler used to call the func

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,T6> io.reactivex.functions.Function6<T1,T2,T3,T4,T5,T6,io.reactivex.Flowable<java.lang.Void>> toAsync(Consumer6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6> action,
                                                                                                                                    io.reactivex.Scheduler scheduler)

Convert a synchronous action call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

T6 - the sixth parameter type

Parameters:

action - the action to convert

scheduler - the Scheduler used to execute the action

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,T6,R> io.reactivex.functions.Function6<T1,T2,T3,T4,T5,T6,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> func,
                                                                                                                         io.reactivex.Scheduler scheduler)

Convert a synchronous function call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

T6 - the sixth parameter type

R - the result type

Parameters:

func - the function to convert

scheduler - the Scheduler used to call the func

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,T6,T7> io.reactivex.functions.Function7<T1,T2,T3,T4,T5,T6,T7,io.reactivex.Flowable<java.lang.Void>> toAsync(Consumer7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7> action,
                                                                                                                                          io.reactivex.Scheduler scheduler)

Convert a synchronous action call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

T6 - the sixth parameter type

T7 - the seventh parameter type

Parameters:

action - the action to convert

scheduler - the Scheduler used to execute the action

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,T6,T7,R> io.reactivex.functions.Function7<T1,T2,T3,T4,T5,T6,T7,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> func,
                                                                                                                               io.reactivex.Scheduler scheduler)

Convert a synchronous function call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

T6 - the sixth parameter type

T7 - the seventh parameter type

R - the result type

Parameters:

func - the function to convert

scheduler - the Scheduler used to call the func

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,T6,T7,T8> io.reactivex.functions.Function8<T1,T2,T3,T4,T5,T6,T7,T8,io.reactivex.Flowable<java.lang.Void>> toAsync(Consumer8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8> action,
                                                                                                                                                io.reactivex.Scheduler scheduler)

Convert a synchronous action call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

T6 - the sixth parameter type

T7 - the seventh parameter type

T8 - the eighth parameter type

Parameters:

action - the action to convert

scheduler - the Scheduler used to execute the action

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,T6,T7,T8,R> io.reactivex.functions.Function8<T1,T2,T3,T4,T5,T6,T7,T8,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> func,
                                                                                                                                     io.reactivex.Scheduler scheduler)

Convert a synchronous function call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

T6 - the sixth parameter type

T7 - the seventh parameter type

T8 - the eighth parameter type

R - the result type

Parameters:

func - the function to convert

scheduler - the Scheduler used to call the func

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,T6,T7,T8,T9> io.reactivex.functions.Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,io.reactivex.Flowable<java.lang.Void>> toAsync(Consumer9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9> action,
                                                                                                                                                      io.reactivex.Scheduler scheduler)

Convert a synchronous action call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

T6 - the sixth parameter type

T7 - the seventh parameter type

T8 - the eighth parameter type

T9 - the ninth parameter type

Parameters:

action - the action to convert

scheduler - the Scheduler used to execute the action

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsync

public static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> io.reactivex.functions.Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,io.reactivex.Flowable<R>> toAsync(io.reactivex.functions.Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> func,
                                                                                                                                           io.reactivex.Scheduler scheduler)

Convert a synchronous function call into an asynchronous function call through an Flowable.

Type Parameters:

T1 - the first parameter type

T2 - the second parameter type

T3 - the third parameter type

T4 - the fourth parameter type

T5 - the fifth parameter type

T6 - the sixth parameter type

T7 - the seventh parameter type

T8 - the eighth parameter type

T9 - the ninth parameter type

R - the result type

Parameters:

func - the function to convert

scheduler - the Scheduler used to call the func

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync(), MSDN: Observable.ToAsync

toAsyncArray

public static io.reactivex.functions.Function<java.lang.Object[],io.reactivex.Flowable<java.lang.Void>> toAsyncArray(io.reactivex.functions.Consumer<? super java.lang.Object[]> action,
                                                                                                                     io.reactivex.Scheduler scheduler)

Convert a synchronous action call into an asynchronous function call through an Flowable.

Parameters:

action - the action to convert

scheduler - the Scheduler used to execute the action

Returns:

a function that returns an Flowable that executes the action and emits null

See Also:

RxJava Wiki: toAsync()

toAsyncArray

public static <R> io.reactivex.functions.Function<java.lang.Object[],io.reactivex.Flowable<R>> toAsyncArray(io.reactivex.functions.Function<? super java.lang.Object[],? extends R> func,
                                                                                                            io.reactivex.Scheduler scheduler)

Convert a synchronous function call into an asynchronous function call through an Flowable.

Type Parameters:

R - the result type

Parameters:

func - the function to convert

scheduler - the Scheduler used to call the func

Returns:

a function that returns an Flowable that executes the func and emits its returned value

See Also:

RxJava Wiki: toAsync()

startFuture

public static <T> io.reactivex.Flowable<T> startFuture(java.util.concurrent.Callable<? extends java.util.concurrent.Future<? extends T>> functionAsync)

Invokes the asynchronous function immediately, surfacing the result through an Observable.

Important note subscribing to the resulting Observable blocks until the future completes.

Type Parameters:

T - the result type

Parameters:

functionAsync - the asynchronous function to run

Returns:

an Observable that surfaces the result of the future

See Also:

startFuture(Callable, Scheduler), RxJava Wiki: startFuture()

startFuture

public static <T> io.reactivex.Flowable<T> startFuture(java.util.concurrent.Callable<? extends java.util.concurrent.Future<? extends T>> functionAsync,
                                                       io.reactivex.Scheduler scheduler)

Invokes the asynchronous function immediately, surfacing the result through an Observable and waits on the specified Scheduler.

Type Parameters:

T - the result type

Parameters:

functionAsync - the asynchronous function to run

scheduler - the Scheduler where the completion of the Future is awaited

Returns:

an Observable that surfaces the result of the future

See Also:

RxJava Wiki: startFuture()

deferFuture

public static <T> io.reactivex.Flowable<T> deferFuture(java.util.concurrent.Callable<? extends java.util.concurrent.Future<? extends org.reactivestreams.Publisher<? extends T>>> observableFactoryAsync)

Returns an Observable that starts the specified asynchronous factory function whenever a new observer subscribes.

Important note subscribing to the resulting Observable blocks until the future completes.

Type Parameters:

T - the result type

Parameters:

observableFactoryAsync - the asynchronous function to start for each observer

Returns:

the Observable emitting items produced by the asynchronous observer produced by the factory

See Also:

deferFuture(Callable, Scheduler), RxJava Wiki: deferFuture()

deferFuture

public static <T> io.reactivex.Flowable<T> deferFuture(java.util.concurrent.Callable<? extends java.util.concurrent.Future<? extends org.reactivestreams.Publisher<? extends T>>> observableFactoryAsync,
                                                       io.reactivex.Scheduler scheduler)

Returns an Observable that starts the specified asynchronous factory function whenever a new observer subscribes.

Type Parameters:

T - the result type

Parameters:

observableFactoryAsync - the asynchronous function to start for each observer

scheduler - the Scheduler where the completion of the Future is awaited

Returns:

the Observable emitting items produced by the asynchronous observer produced by the factory

See Also:

RxJava Wiki: deferFuture()

forEachFuture

public static <T> java.util.concurrent.FutureTask<java.lang.Void> forEachFuture(org.reactivestreams.Publisher<? extends T> source,
                                                                                io.reactivex.functions.Consumer<? super T> onNext)

Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future.

Important note: The returned task blocks indefinitely unless the run() method is called or the task is scheduled on an Executor.

Type Parameters:

T - the source value type

Parameters:

source - the source Observable

onNext - the action to call with each emitted element

Returns:

the Future representing the entire for-each operation

See Also:

forEachFuture(Publisher, Consumer, Scheduler), RxJava Wiki: forEachFuture()

forEachFuture

public static <T> java.util.concurrent.FutureTask<java.lang.Void> forEachFuture(org.reactivestreams.Publisher<? extends T> source,
                                                                                io.reactivex.functions.Consumer<? super T> onNext,
                                                                                io.reactivex.functions.Consumer<? super java.lang.Throwable> onError)

Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future.

Important note: The returned task blocks indefinitely unless the run() method is called or the task is scheduled on an Executor.

Type Parameters:

T - the source value type

Parameters:

source - the source Observable

onNext - the action to call with each emitted element

onError - the action to call when an exception is emitted

Returns:

the Future representing the entire for-each operation

See Also:

forEachFuture(Publisher, Consumer, Consumer, Scheduler), RxJava Wiki: forEachFuture()

forEachFuture

public static <T> java.util.concurrent.FutureTask<java.lang.Void> forEachFuture(org.reactivestreams.Publisher<? extends T> source,
                                                                                io.reactivex.functions.Consumer<? super T> onNext,
                                                                                io.reactivex.functions.Consumer<? super java.lang.Throwable> onError,
                                                                                io.reactivex.functions.Action onCompleted)

Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future.

Important note: The returned task blocks indefinitely unless the run() method is called or the task is scheduled on an Executor.

Type Parameters:

T - the source value type

Parameters:

source - the source Observable

onNext - the action to call with each emitted element

onError - the action to call when an exception is emitted

onCompleted - the action to call when the source completes

Returns:

the Future representing the entire for-each operation

See Also:

forEachFuture(Publisher, Consumer, Consumer, Action, Scheduler), RxJava Wiki: forEachFuture()

forEachFuture

public static <T> java.util.concurrent.FutureTask<java.lang.Void> forEachFuture(org.reactivestreams.Publisher<? extends T> source,
                                                                                io.reactivex.functions.Consumer<? super T> onNext,
                                                                                io.reactivex.Scheduler scheduler)

Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future, scheduled on the given scheduler.

Type Parameters:

T - the source value type

Parameters:

source - the source Observable

onNext - the action to call with each emitted element

scheduler - the Scheduler where the task will await the termination of the for-each

Returns:

the Future representing the entire for-each operation

See Also:

RxJava Wiki: forEachFuture()

forEachFuture

public static <T> java.util.concurrent.FutureTask<java.lang.Void> forEachFuture(org.reactivestreams.Publisher<? extends T> source,
                                                                                io.reactivex.functions.Consumer<? super T> onNext,
                                                                                io.reactivex.functions.Consumer<? super java.lang.Throwable> onError,
                                                                                io.reactivex.Scheduler scheduler)

Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future, scheduled on the given Scheduler.

Type Parameters:

T - the source value type

Parameters:

source - the source Observable

onNext - the action to call with each emitted element

onError - the action to call when an exception is emitted

scheduler - the Scheduler where the task will await the termination of the for-each

Returns:

the Future representing the entire for-each operation

See Also:

RxJava Wiki: forEachFuture()

forEachFuture

public static <T> java.util.concurrent.FutureTask<java.lang.Void> forEachFuture(org.reactivestreams.Publisher<? extends T> source,
                                                                                io.reactivex.functions.Consumer<? super T> onNext,
                                                                                io.reactivex.functions.Consumer<? super java.lang.Throwable> onError,
                                                                                io.reactivex.functions.Action onCompleted,
                                                                                io.reactivex.Scheduler scheduler)

Subscribes to the given source and calls the callback for each emitted item, and surfaces the completion or error through a Future, scheduled on the given Scheduler.

Type Parameters:

T - the source value type

Parameters:

source - the source Observable

onNext - the action to call with each emitted element

onError - the action to call when an exception is emitted

onCompleted - the action to call when the source completes

scheduler - the Scheduler where the task will await the termination of the for-each

Returns:

the Future representing the entire for-each operation

See Also:

RxJava Wiki: forEachFuture()

runAsync

public static <T> DisposableFlowable<T> runAsync(io.reactivex.Scheduler scheduler,
                                                 io.reactivex.functions.BiConsumer<? super org.reactivestreams.Subscriber<? super T>,? super org.reactivestreams.Subscription> action)

Runs the provided action on the given scheduler and allows propagation of multiple events to the observers of the returned StoppableObservable. The action is immediately executed and unobserved values will be lost.

Type Parameters:

T - the output value type

Parameters:

scheduler - the Scheduler where the action is executed

action - the action to execute, receives a Subscriber where the events can be pumped and a Subscription which lets it check for cancellation condition

Returns:

an Observable that provides a Subscription interface to cancel the action

See Also:

RxJava Wiki: runAsync()

runAsync

public static <T,U> DisposableFlowable<U> runAsync(io.reactivex.Scheduler scheduler,
                                                   org.reactivestreams.Processor<T,U> processor,
                                                   io.reactivex.functions.BiConsumer<? super org.reactivestreams.Subscriber<? super T>,? super org.reactivestreams.Subscription> action)

Runs the provided action on the given scheduler and allows propagation of multiple events to the observers of the returned StoppableObservable. The action is immediately executed and unobserved values might be lost, depending on the Subject type used.

Type Parameters:

T - the output value of the action

U - the output type of the observable sequence

Parameters:

scheduler - the Scheduler where the action is executed

processor - the subject to use to distribute values emitted by the action

action - the action to execute, receives a Subscriber where the events can be pumped and a Subscription which lets it check for cancellation condition

Returns:

an Observable that provides a Subscription interface to cancel the action

See Also:

RxJava Wiki: runAsync()