File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
rxjava-core/src/main/java/rx Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff 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 ;
Original file line number Diff line number Diff 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 ;
You can’t perform that action at this time.
0 commit comments