1.x: onErrorResumeNext(Func1) should not call plugin handler there

Author: akarnokd

src/main/java/rx/internal/operators/OperatorOnErrorResumeNextViaFunction.java

@@ -70,11 +70,11 @@ public void onCompleted() {
             public void onError(Throwable e) {
                 if (done) {
                     Exceptions.throwIfFatal(e);
+                    RxJavaPlugins.getInstance().getErrorHandler().handleError(e);
                     return;
                 }
                 done = true;
                 try {
-                    RxJavaPlugins.getInstance().getErrorHandler().handleError(e);
                     unsubscribe();
                     Subscriber<T> next = new Subscriber<T>() {
                         @Override

src/main/java/rx/internal/operators/OperatorOnErrorResumeNextViaObservable.java

@@ -68,10 +68,10 @@ public void onNext(T t) {
             public void onError(Throwable e) {
                 if (done) {
                     Exceptions.throwIfFatal(e);
+                    RxJavaPlugins.getInstance().getErrorHandler().handleError(e);
                     return;
                 }
                 done = true;
-                RxJavaPlugins.getInstance().getErrorHandler().handleError(e);
                 unsubscribe();
                 resumeSequence.unsafeSubscribe(child);
             }

src/main/java/rx/internal/operators/OperatorOnErrorReturn.java

@@ -69,11 +69,11 @@ public void onNext(T t) {
             public void onError(Throwable e) {
                 if (done) {
                     Exceptions.throwIfFatal(e);
+                    RxJavaPlugins.getInstance().getErrorHandler().handleError(e);
                     return;
                 }
                 done = true;
                 try {
-                    RxJavaPlugins.getInstance().getErrorHandler().handleError(e);
                     unsubscribe();
                     T result = resultFunction.call(e);
                     child.onNext(result);

src/main/java/rx/internal/operators/OperatorOnExceptionResumeNextViaObservable.java

@@ -72,11 +72,11 @@ public void onNext(T t) {
             public void onError(Throwable e) {
                 if (done) {
                     Exceptions.throwIfFatal(e);
+                    RxJavaPlugins.getInstance().getErrorHandler().handleError(e);
                     return;
                 }
                 done = true;
                 if (e instanceof Exception) {
-                    RxJavaPlugins.getInstance().getErrorHandler().handleError(e);
                     unsubscribe();
                     resumeSequence.unsafeSubscribe(child);
                 } else {