1.x: Add Single.onErrorResumeNext(Single)#3655
Conversation
There was a problem hiding this comment.
Why not implement this via SingleOnSubscribe and then you have access to SingleSubscriber without the API mismatch with backpressured Operators?
There was a problem hiding this comment.
Good point, will do.
On Fri, 29 Jan 2016, 11:08 David Karnok notifications@github.com wrote:
In
src/main/java/rx/internal/operators/SingleOperatorOnErrorResumeNextViaSingle.java
#3655 (comment):@@ -0,0 +1,67 @@
+package rx.internal.operators;
+
+import rx.Observable.Operator;
+import rx.Producer;
+import rx.Single;
+import rx.Subscriber;
+import rx.exceptions.Exceptions;
+import rx.plugins.RxJavaPlugins;
+
+public class SingleOperatorOnErrorResumeNextViaSingle implements Operator<T, T> {Why not implement this via SingleOnSubscribe and then you have access to
SingleSubscriber without the API mismatch with backpressured Operators?—
Reply to this email directly or view it on GitHub
https://github.com/ReactiveX/RxJava/pull/3655/files#r51234767.
@artem_zin
0c44ad2 to
67ef32c
Compare
|
@akarnokd changed to |
|
👍 |
|
@zsxwing PTAL :) |
|
👍 |
…extViaSingle 1.x: Add Single.onErrorResumeNext(Single)
|
👍 |
Part of #3652, will submit a PR for
onErrorResumeNext(Func1<Throwable, Single>)later.