2.x: test sync + cleanup #4204
Conversation
akarnokd
added Enhancement Test
labels
Jul 14, 2016
akarnokd
added this to the
2.0 RC 1
milestone
Jul 14, 2016
akarnokd
added
some commits
Jul 14, 2016
codecov-io
commented
Jul 14, 2016
•
Current coverage is 68.54%@@ 2.x #4204 diff @@
==========================================
Files 409 411 +2
Lines 29450 29486 +36
Methods 0 0
Messages 0 0
Branches 4763 4777 +14
==========================================
+ Hits 20092 20211 +119
+ Misses 7331 7262 -69
+ Partials 2027 2013 -14
|
Anybody wants to review this? |
Yes, will do in couple days (busy, sorry) On Mon, 18 Jul 2016, 01:22 David Karnok, notifications@github.com wrote:
|
I'm merging this so we can progress with other tasks that would affect the same files. I'll address the review feedback in a separate PR if necessary. |
akarnokd
merged commit 487a0ba
into ReactiveX:2.x Jul 18, 2016
1 check passed
akarnokd
deleted the
akarnokd:TestSync714_1 branch
Jul 18, 2016
artem-zinnatullin
commented on the diff
Jul 18, 2016
} | ||
group = 'io.reactivex.rxjava2' | ||
description = 'RxJava: Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.' | ||
apply plugin: 'java' | ||
-apply plugin: 'pmd' | ||
+// apply plugin: 'pmd' |
artem-zinnatullin
Contributor
|
artem-zinnatullin
commented on the diff
Jul 18, 2016
@@ -18,7 +18,11 @@ | ||
private static final long serialVersionUID = -6179993283427447098L; | ||
public OnCompleteFailedException(Throwable cause) { | ||
- super(cause); | ||
+ super(cause != null ? cause : new NullPointerException()); |
artem-zinnatullin
Contributor
|
artem-zinnatullin
commented on the diff
Jul 18, 2016
+ | ||
+ return v; | ||
+ } | ||
+ throw new NoSuchElementException(); | ||
+ } | ||
+ | ||
+ @Override | ||
+ public void onSubscribe(Subscription s) { | ||
+ if (SubscriptionHelper.setOnce(this, s)) { | ||
+ s.request(batchSize); | ||
+ } | ||
+ } | ||
+ | ||
+ @Override | ||
+ public void onNext(T t) { | ||
+ if (!queue.offer(t)) { |
|
akarnokd commentedJul 14, 2016
TestObserver
cleanup and sync withTestSubscriber
;combineLatest
, introducedcombineLatestDelayError
;test
prefix in the method names!