diff --git a/src/main/java/rx/util/async/Async.java b/src/main/java/rx/util/async/Async.java
index 0e800fc..d3e5401 100644
--- a/src/main/java/rx/util/async/Async.java
+++ b/src/main/java/rx/util/async/Async.java
@@ -45,7 +45,7 @@ private Async() {
* Note: The function is called immediately and once, not whenever an observer subscribes to the resulting
* Observable. Multiple subscriptions to this Observable observe the same return value.
*
- *
+ *
*
* @param the result value type
* @param func function to run asynchronously
@@ -64,7 +64,7 @@ public static Observable start(Func0 func) {
* Note: The function is called immediately and once, not whenever an observer subscribes to the resulting
* Observable. Multiple subscriptions to this Observable observe the same return value.
*
- *
+ *
*
* @param the result value type
* @param func function to run asynchronously
@@ -80,7 +80,7 @@ public static Observable start(Func0 func, Scheduler scheduler) {
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param action the action to convert
* @return a function that returns an Observable that executes the {@code action} and emits {@code null}
@@ -94,7 +94,7 @@ public static Func0> toAsync(Action0 action) {
/**
* Convert a synchronous function call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the result value type
* @param func the function to convert
@@ -109,7 +109,7 @@ public static Func0> toAsync(Func0 extends R> func) {
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param first parameter type of the action
* @param action the action to convert
@@ -124,7 +124,7 @@ public static Func1> toAsync(Action1 super T1> actio
/**
* Convert a synchronous function call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param first parameter type of the action
* @param the result type
@@ -140,7 +140,7 @@ public static Func1> toAsync(Func1 super T1, ? exten
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -156,7 +156,7 @@ public static Func2> toAsync(Action2 super T
/**
* Convert a synchronous function call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -173,7 +173,7 @@ public static Func2> toAsync(Func2 super T1,
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -190,7 +190,7 @@ public static Func3> toAsync(Action3
/**
* Convert a synchronous function call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -208,7 +208,7 @@ public static Func3> toAsync(Func3 s
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -226,7 +226,7 @@ public static Func4> toAsync(A
/**
* Convert a synchronous function call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -245,7 +245,7 @@ public static Func4> toAsync(F
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -264,7 +264,7 @@ public static Func5> t
/**
* Convert a synchronous function call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -284,7 +284,7 @@ public static Func5> t
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -304,7 +304,7 @@ public static Func6
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -325,7 +325,7 @@ public static Func6
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -346,7 +346,7 @@ public static Func7
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -368,7 +368,7 @@ public static Func7
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -390,7 +390,7 @@ public static Func8
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -413,7 +413,7 @@ public static Func8
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -436,7 +436,7 @@ public static Func9
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -460,7 +460,7 @@ public static Func9
- *
+ *
*
* @param action the action to convert
* @return a function that returns an Observable that executes the {@code action} and emits {@code null}
@@ -473,7 +473,7 @@ public static FuncN> toAsync(ActionN action) {
/**
* Convert a synchronous function call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the result type
* @param func the function to convert
@@ -487,7 +487,7 @@ public static FuncN> toAsync(FuncN extends R> func) {
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param action the action to convert
* @param scheduler the Scheduler used to execute the {@code action}
@@ -502,7 +502,7 @@ public static Func0> toAsync(final Action0 action, final Schedu
/**
* Convert a synchronous function call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the result type
* @param func the function to convert
@@ -541,7 +541,7 @@ public void call() {
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param action the Action to convert
@@ -557,7 +557,7 @@ public static Func1> toAsync(final Action1 super T1>
/**
* Convert a synchronous function call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the result type
@@ -597,7 +597,7 @@ public void call() {
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -614,7 +614,7 @@ public static Func2> toAsync(final Action2 s
/**
* Convert a synchronous function call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -655,7 +655,7 @@ public void call() {
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -673,7 +673,7 @@ public static Func3> toAsync(final Act
/**
* Convert a synchronous function call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -715,7 +715,7 @@ public void call() {
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -734,7 +734,7 @@ public static Func4> toAsync(f
/**
* Convert a synchronous function call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -777,7 +777,7 @@ public void call() {
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -797,7 +797,7 @@ public static Func5> t
/**
* Convert a synchronous function call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -841,7 +841,7 @@ public void call() {
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -862,7 +862,7 @@ public static Func6
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -907,7 +907,7 @@ public void call() {
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -929,7 +929,7 @@ public static Func7
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -975,7 +975,7 @@ public void call() {
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -998,7 +998,7 @@ public static Func8
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -1045,7 +1045,7 @@ public void call() {
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -1069,7 +1069,7 @@ public static Func9
- *
+ *
*
* @param the first parameter type
* @param the second parameter type
@@ -1117,7 +1117,7 @@ public void call() {
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param action the action to convert
* @param scheduler the Scheduler used to execute the {@code action}
@@ -1131,7 +1131,7 @@ public static FuncN> toAsync(final ActionN action, final Schedu
/**
* Convert a synchronous function call into an asynchronous function call through an Observable.
*
- *
+ *
*
* @param the result type
* @param func the function to convert
@@ -1169,7 +1169,7 @@ public void call() {
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* Alias for toAsync(ActionN) intended for dynamic languages.
*
@@ -1184,7 +1184,7 @@ public static FuncN> asyncAction(final ActionN action) {
/**
* Convert a synchronous action call into an asynchronous function call through an Observable.
*
- *
+ *
*
* Alias for toAsync(ActionN, Scheduler) intended for dynamic languages.
*
@@ -1200,7 +1200,7 @@ public static FuncN> asyncAction(final ActionN action, final Sc
/**
* Convert a synchronous function call into an asynchronous function call through an Observable.
*
- *
+ *
*
* Alias for toAsync(FuncN) intended for dynamic languages.
*
@@ -1216,7 +1216,7 @@ public static FuncN> asyncFunc(final FuncN extends R> func)
/**
* Convert a synchronous function call into an asynchronous function call through an Observable.
*
- *
+ *
*
* Alias for {@code toAsync(FuncN, Scheduler)} intended for dynamic languages.
*
@@ -1235,7 +1235,7 @@ public static FuncN> asyncFunc(final FuncN extends R> func,
*
* Important note subscribing to the resulting Observable blocks until the future completes.
*
- *
+ *
*
* @param the result type
* @param functionAsync the asynchronous function to run
@@ -1251,7 +1251,7 @@ public static Observable startFuture(Func0 extends Future extends T>>
* Invokes the asynchronous function immediately, surfacing the result through an Observable and waits on
* the specified Scheduler.
*
- *
+ *
*
* @param the result type
* @param functionAsync the asynchronous function to run
@@ -1270,7 +1270,7 @@ public static Observable startFuture(Func0 extends Future extends T>>
*
* Important note subscribing to the resulting Observable blocks until the future completes.
*
- *
+ *
*
* @param the result type
* @param observableFactoryAsync the asynchronous function to start for each observer
@@ -1286,7 +1286,7 @@ public static Observable deferFuture(Func0 extends Future extends Obs
* Returns an Observable that starts the specified asynchronous factory function whenever a new observer
* subscribes.
*
- *
+ *
*
* @param the result type
* @param observableFactoryAsync the asynchronous function to start for each observer
@@ -1307,7 +1307,7 @@ public static Observable deferFuture(
* Important note: The returned task blocks indefinitely unless the {@code run()} method is called
* or the task is scheduled on an Executor.
*
- *
+ *
*
* @param the source value type
* @param source the source Observable
@@ -1330,7 +1330,7 @@ public static FutureTask forEachFuture(
* Important note: The returned task blocks indefinitely unless the {@code run()} method is called
* or the task is scheduled on an Executor.
*
- *
+ *
*
* @param the source value type
* @param source the source Observable
@@ -1355,7 +1355,7 @@ public static FutureTask forEachFuture(
* Important note: The returned task blocks indefinitely unless the {@code run()} method is called
* or the task is scheduled on an Executor.
*
- *
+ *
*
* @param the source value type
* @param source the source Observable
@@ -1379,7 +1379,7 @@ public static FutureTask forEachFuture(
* 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.
*
- *
+ *
*
* @param the source value type
* @param source the source Observable
@@ -1403,7 +1403,7 @@ public static FutureTask forEachFuture(
* 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.
*
- *
+ *
*
* @param the source value type
* @param source the source Observable
@@ -1429,7 +1429,7 @@ public static FutureTask forEachFuture(
* 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.
*
- *
+ *
*
* @param the source value type
* @param source the source Observable
@@ -1455,7 +1455,7 @@ public static FutureTask forEachFuture(
/**
* Return an Observable that calls the given action and emits the given result when an Observer subscribes.
*
- *
+ *
*
* The action is run on the default thread pool for computation.
*
@@ -1473,7 +1473,7 @@ public static Observable fromAction(Action0 action, R result) {
* Return an Observable that calls the given Callable and emits its result or Exception when an Observer
* subscribes.
*
- *
+ *
*
* The Callable is called on the default thread pool for computation.
*
@@ -1492,7 +1492,7 @@ public static Observable fromCallable(Callable extends R> callable) {
* Return an Observable that calls the given Runnable and emits the given result when an Observer
* subscribes.
*
- *
+ *
*
* The Runnable is called on the default thread pool for computation.
*
@@ -1510,7 +1510,7 @@ public static Observable fromRunnable(final Runnable run, final R result)
/**
* Return an Observable that calls the given action and emits the given result when an Observer subscribes.
*
- *
+ *
*
* @param the return type
* @param action the action to invoke on each subscription
@@ -1527,7 +1527,7 @@ public static Observable fromAction(Action0 action, R result, Scheduler s
* Return an Observable that calls the given Callable and emits its result or Exception when an Observer
* subscribes.
*
- *
+ *
*
* @param the return type
* @param callable the callable to call on each subscription
@@ -1545,7 +1545,7 @@ public static Observable fromCallable(Callable extends R> callable, Sch
* Return an Observable that calls the given Runnable and emits the given result when an Observer
* subscribes.
*
- *
+ *
*
* @param the return type
* @param run the runnable to invoke on each subscription