refine

meowpunch · meowpunch · commit 81c3b83bec51 · 2022-10-16T13:53:43.000+02:00
diff --git a/src/main/java/concurrency/reactive/IntervalEx.java b/src/main/java/concurrency/reactive/IntervalEx.java
@@ -63,7 +63,7 @@ public void onSubscribe(Subscription s) {
           @Override
           public void onNext(Integer integer) {
             if (count++ >= n) subscription.cancel();
-            subscriber.onNext(integer);
+            else subscriber.onNext(integer);
           }
 
           @Override

Original file line number	Diff line number	Diff line change
`@@ -63,7 +63,7 @@ public void onSubscribe(Subscription s) {`
`63`	`63`	`@Override`
`64`	`64`	`public void onNext(Integer integer) {`
`65`	`65`	`if (count++ >= n) subscription.cancel();`
`66`		`- subscriber.onNext(integer);`
	`66`	`+ else subscriber.onNext(integer);`
`67`	`67`	`}`
`68`	`68`
`69`	`69`	`@Override`