-
Notifications
You must be signed in to change notification settings - Fork 7.6k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
2.x: Add efficient concatWith(Single|Maybe|Completable) overloads #5845
Conversation
Codecov Report
@@ Coverage Diff @@
## 2.x #5845 +/- ##
============================================
+ Coverage 96.38% 96.42% +0.04%
- Complexity 5812 5835 +23
============================================
Files 634 640 +6
Lines 41760 41944 +184
Branches 5796 5804 +8
============================================
+ Hits 40251 40446 +195
+ Misses 591 580 -11
Partials 918 918
Continue to review full report at Codecov.
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Good stuff.
} else { | ||
inMaybe = true; | ||
s = SubscriptionHelper.CANCELLED; | ||
MaybeSource<? extends T> c = other; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
should probably be named m
@Override | ||
public void onComplete() { | ||
s = SubscriptionHelper.CANCELLED; | ||
SingleSource<? extends T> c = other; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
should probably be named s
. But then it's conflicting with the subscription s
. So I guess ss
would be more appropriate.
} else { | ||
inMaybe = true; | ||
DisposableHelper.replace(this, null); | ||
MaybeSource<? extends T> c = other; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
should probably be named m
public void onComplete() { | ||
inSingle = true; | ||
DisposableHelper.replace(this, null); | ||
SingleSource<? extends T> c = other; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
same here
This PR adds specialized overloads to the
concatWith
operator inFlowable
andObservable
.If accepted, the marbles will be updated in a separate PR.
Related: #5350.