Update Tests for doOn* Changes

Author: benjchristensen

rxjava-core/src/test/java/rx/ObservableDoOnTest.java

@@ -30,7 +30,7 @@ public class ObservableDoOnTest {
     @Test
     public void testDoOnEach() {
         final AtomicReference<String> r = new AtomicReference<String>();
-        String output = Observable.from("one").doOnEach(new Action1<String>() {
+        String output = Observable.from("one").doOnNext(new Action1<String>() {
 
             @Override
             public void call(String v) {

rxjava-core/src/test/java/rx/operators/OperationDoOnEachTest.java

@@ -108,7 +108,7 @@ public String call(String s) {
     @Test
     public void testDoOnEachWithErrorInCallback() {
         Observable<String> base     = Observable.from("one", "two", "fail", "three");
-        Observable<String> doOnEach = base.doOnEach(new Action1<String>() {
+        Observable<String> doOnEach = base.doOnNext(new Action1<String>() {
             @Override
             public void call(String s) {
                 if ("fail".equals(s)) {

rxjava-core/src/test/java/rx/operators/OperationObserveOnTest.java

@@ -98,7 +98,7 @@ public void testThreadName() throws InterruptedException {
         final CountDownLatch completedLatch = new CountDownLatch(1);
 
         // assert subscribe is on main thread
-        obs = obs.doOnEach(new Action1<String>() {
+        obs = obs.doOnNext(new Action1<String>() {
 
             @Override
             public void call(String s) {
@@ -110,7 +110,7 @@ public void call(String s) {
         });
 
         // assert observe is on new thread
-        obs.observeOn(Schedulers.newThread()).doOnEach(new Action1<String>() {
+        obs.observeOn(Schedulers.newThread()).doOnNext(new Action1<String>() {
 
             @Override
             public void call(String t1) {