1.x: Add Single.onErrorResumeNext(Single) #3655
Conversation
artem-zinnatullin
changed the title
| import rx.exceptions.Exceptions; | ||
| import rx.plugins.RxJavaPlugins; | ||
|
|
||
| public class SingleOperatorOnErrorResumeNextViaSingle<T> implements Operator<T, T> { |
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
artem-zinnatullin
force-pushed
the
single-onErrorResumeNextViaSingle
branch
from
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.