Remove ExecutorScheduler - New ComputationScheduler

- see ReactiveX/RxJava#711 and ReactiveX/RxJava#713
ReactiveX · Apr 19, 2014 · 670fbb2 · 670fbb2
1 parent 5f38ca6
commit 670fbb2
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/src/test/java/rx/util/async/operators/OperationDeferFutureTest.java b/src/test/java/rx/util/async/operators/OperationDeferFutureTest.java
@@ -58,7 +58,7 @@ public Observable<Integer> call() throws Exception {
                 }
             };
 
-            Observable<Integer> result = Async.deferFuture(func, Schedulers.threadPoolForComputation());
+            Observable<Integer> result = Async.deferFuture(func, Schedulers.computation());
 
             final Observer<Integer> observer = mock(Observer.class);
 

diff --git a/src/test/java/rx/util/async/operators/OperationForEachFutureTest.java b/src/test/java/rx/util/async/operators/OperationForEachFutureTest.java
@@ -54,7 +54,7 @@ public void testSimple() {
 
         try {
             Observable<Integer> source = Observable.from(1, 2, 3)
-                    .subscribeOn(Schedulers.threadPoolForComputation());
+                    .subscribeOn(Schedulers.computation());
 
             final AtomicInteger sum = new AtomicInteger();
             Action1<Integer> add = new Action1<Integer>() {
@@ -93,7 +93,7 @@ public void testSimpleThrowing() {
 
         try {
             Observable<Integer> source = Observable.<Integer>error(new CustomException())
-                    .subscribeOn(Schedulers.threadPoolForComputation());
+                    .subscribeOn(Schedulers.computation());
 
             final AtomicInteger sum = new AtomicInteger();
             Action1<Integer> add = new Action1<Integer>() {
@@ -128,7 +128,7 @@ public void call(Integer t1) {
     @Test
     public void testSimpleScheduled() {
         Observable<Integer> source = Observable.from(1, 2, 3)
-                .subscribeOn(Schedulers.threadPoolForComputation());
+                .subscribeOn(Schedulers.computation());
 
         final AtomicInteger sum = new AtomicInteger();
         Action1<Integer> add = new Action1<Integer>() {
@@ -158,7 +158,7 @@ public void call(Integer t1) {
     public void testSimpleScheduledThrowing() {
 
         Observable<Integer> source = Observable.<Integer>error(new CustomException())
-                .subscribeOn(Schedulers.threadPoolForComputation());
+                .subscribeOn(Schedulers.computation());
 
         final AtomicInteger sum = new AtomicInteger();
         Action1<Integer> add = new Action1<Integer>() {

diff --git a/src/test/java/rx/util/async/operators/OperationStartFutureTest.java b/src/test/java/rx/util/async/operators/OperationStartFutureTest.java
@@ -104,7 +104,7 @@ public Integer call() throws Exception {
                 }
             };
 
-            Observable<Integer> result = Async.startFuture(func, Schedulers.threadPoolForComputation());
+            Observable<Integer> result = Async.startFuture(func, Schedulers.computation());
 
             final Observer<Integer> observer = mock(Observer.class);
-Original file line number
+Diff line change
@@ Expand Up / @@ -58,7 +58,7 @@ public Observable<Integer> call() throws Exception { @@
                     }
                 };
-                Observable<Integer> result = Async.deferFuture(func, Schedulers.threadPoolForComputation());
+                Observable<Integer> result = Async.deferFuture(func, Schedulers.computation());
                 final Observer<Integer> observer = mock(Observer.class);
@@ Expand Down @@