Skip to content

Commit cf8a502

Browse files
Re-order count increment to make unit tests deterministic
1 parent ada6a68 commit cf8a502

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

rxjava-core/src/main/java/rx/Observable.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4285,10 +4285,10 @@ public Subscription call(final Observer<String> observer) {
42854285

42864286
@Override
42874287
public void run() {
4288+
counter.incrementAndGet();
42884289
System.out.println("published observable being executed");
42894290
observer.onNext("one");
42904291
observer.onCompleted();
4291-
counter.incrementAndGet();
42924292
}
42934293
}).start();
42944294
return subscription;
@@ -4345,10 +4345,10 @@ public Subscription call(final Observer<String> observer) {
43454345

43464346
@Override
43474347
public void run() {
4348+
counter.incrementAndGet();
43484349
System.out.println("published observable being executed");
43494350
observer.onNext("one");
43504351
observer.onCompleted();
4351-
counter.incrementAndGet();
43524352
}
43534353
}).start();
43544354
return subscription;

rxjava-core/src/main/java/rx/operators/OperationCache.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,10 +83,10 @@ public Subscription call(final Observer<String> observer) {
8383

8484
@Override
8585
public void run() {
86+
counter.incrementAndGet();
8687
System.out.println("published observable being executed");
8788
observer.onNext("one");
8889
observer.onCompleted();
89-
counter.incrementAndGet();
9090
}
9191
}).start();
9292
return subscription;

0 commit comments

Comments
 (0)