ToAsync implemented: Issue #95

rxjava-core/src/main/java/rx/concurrency/Schedulers.java

@@ -96,7 +96,16 @@ public static Scheduler executor(ScheduledExecutorService executor) {
     public static Scheduler threadPoolForComputation() {
         return executor(COMPUTATION_EXECUTOR);
     }
-
+    /**
+     * {@link Scheduler} intended for asynchronous conversions.
+     * <p>
+     * Defaults to {@link #threadPoolForComputation()}.
+     * 
+     * @return {@link ExecutorScheduler} for asynchronous conversion work.
+     */
+    public static Scheduler threadPoolForAsyncConversions() {
+        return threadPoolForComputation();
+    }
     /**
      * {@link Scheduler} intended for IO-bound work.
      * <p>

rxjava-core/src/main/java/rx/util/functions/Action4.java

@@ -0,0 +1,24 @@
+/**
+ * Copyright 2013 Netflix, Inc.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package rx.util.functions;
+
+/**
+ * A four-argument action.
+ */
+public interface Action4<T1, T2, T3, T4> extends Action {
+    void call(T1 t1, T2 t2, T3 t3, T4 t4);
+}

rxjava-core/src/main/java/rx/util/functions/Action5.java

@@ -0,0 +1,24 @@
+/**
+ * Copyright 2013 Netflix, Inc.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package rx.util.functions;
+
+/**
+ * A five-argument action.
+ */
+public interface Action5<T1, T2, T3, T4, T5> extends Action {
+    void call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5);
+}

rxjava-core/src/main/java/rx/util/functions/Action6.java

@@ -0,0 +1,24 @@
+/**
+ * Copyright 2013 Netflix, Inc.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package rx.util.functions;
+
+/**
+ * A six-argument action.
+ */
+public interface Action6<T1, T2, T3, T4, T5, T6> extends Action {
+    void call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6);
+}

rxjava-core/src/main/java/rx/util/functions/Action7.java

@@ -0,0 +1,23 @@
+/**
+ * Copyright 2013 Netflix, Inc.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package rx.util.functions;
+
+/**
+ * A seven-argument action.
+ */
+public interface Action7<T1, T2, T3, T4, T5, T6, T7> extends Action {
+    void call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7);
+}

rxjava-core/src/main/java/rx/util/functions/Action8.java

@@ -0,0 +1,23 @@
+/**
+ * Copyright 2013 Netflix, Inc.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package rx.util.functions;
+
+/**
+ * An eight-argument action.
+ */
+public interface Action8<T1, T2, T3, T4, T5, T6, T7, T8> extends Action {
+    void call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8);
+}

rxjava-core/src/main/java/rx/util/functions/Action9.java

@@ -0,0 +1,23 @@
+/**
+ * Copyright 2013 Netflix, Inc.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package rx.util.functions;
+
+/**
+ * A nine-argument action.
+ */
+public interface Action9<T1, T2, T3, T4, T5, T6, T7, T8, T9> extends Action {
+    void call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9);
+}

rxjava-core/src/main/java/rx/util/functions/ActionN.java

@@ -0,0 +1,23 @@
+/**
+ * Copyright 2013 Netflix, Inc.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package rx.util.functions;
+
+/**
+ * A vector-argument action.
+ */
+public interface ActionN extends Action {
+    void call(Object... args);
+}