File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -329,7 +329,7 @@ Sometimes, there is an implicit data dependency between the previous sequence an
329
329
AtomicInteger count = new AtomicInteger();
330
330
331
331
Observable.range(1, 10)
332
- .doOnNext(ingored -> count.incrementAndGet())
332
+ .doOnNext(ignored -> count.incrementAndGet())
333
333
.ignoreElements()
334
334
.andThen(Single.just(count.get()))
335
335
.subscribe(System.out::println);
@@ -341,7 +341,7 @@ Unfortunately, this prints `0` because `Single.just(count.get())` is evaluated a
341
341
AtomicInteger count = new AtomicInteger ();
342
342
343
343
Observable . range(1 , 10 )
344
- .doOnNext(ingored - > count. incrementAndGet())
344
+ .doOnNext(ignored - > count. incrementAndGet())
345
345
.ignoreElements()
346
346
.andThen(Single . defer(() - > Single . just(count. get())))
347
347
.subscribe(System . out:: println);
353
353
AtomicInteger count = new AtomicInteger ();
354
354
355
355
Observable . range(1 , 10 )
356
- .doOnNext(ingored - > count. incrementAndGet())
356
+ .doOnNext(ignored - > count. incrementAndGet())
357
357
.ignoreElements()
358
358
.andThen(Single . fromCallable(() - > count. get()))
359
359
.subscribe(System . out:: println);
You can’t perform that action at this time.
0 commit comments