File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -545,7 +545,7 @@ Observable.create(new OnSubscribeFunc<Integer>() {
545
545
@Override
546
546
public void run () {
547
547
int i = 0 ;
548
- while (s. isUnsubscribed()) {
548
+ while (! s. isUnsubscribed()) {
549
549
o. onNext(i++ );
550
550
}
551
551
}
@@ -565,7 +565,7 @@ Observable.create(new OnSubscribe<Integer>() {
565
565
@Override
566
566
public void call (Subscriber<? super Integer > subscriber ) {
567
567
int i = 0 ;
568
- while (subscriber. isUnsubscribed()) {
568
+ while (! subscriber. isUnsubscribed()) {
569
569
subscriber. onNext(i++ );
570
570
}
571
571
}
@@ -584,7 +584,7 @@ Observable.create(new OnSubscribe<Integer>() {
584
584
@Override
585
585
public void run () {
586
586
int i = 0 ;
587
- while (subscriber. isUnsubscribed()) {
587
+ while (! subscriber. isUnsubscribed()) {
588
588
subscriber. onNext(i++ );
589
589
}
590
590
}
@@ -603,7 +603,7 @@ Observable.create(new OnSubscribe<Integer>() {
603
603
@Override
604
604
public void call (Subscriber<? super Integer > subscriber ) {
605
605
int i = 0 ;
606
- while (subscriber. isUnsubscribed()) {
606
+ while (! subscriber. isUnsubscribed()) {
607
607
subscriber. onNext(i++ );
608
608
}
609
609
}
You can’t perform that action at this time.
0 commit comments