Flux 不发射元素

Question

我在玩 Reactor 的通量 api。我已经熟悉 RxJava，所以我想测试一下 Reactor 的 Flux。 我不明白为什么我在以下代码中总是收到 0：

Flux.create(e -> {
        long current = 1;
        while (!e.isCancelled()) {
            e.next(current);
            current *= 2;
        }
    })
        .subscribe(l -> System.out.println("Got " + l + " on " + Thread.currentThread().getName()), e -> System.out.println(e.getMessage() + "!!!!"), () -> System.out.println("finished"));

当我运行代码时，我会看到无数行显示 “在 main 上得到 0”

Answer 1

你有 Long 溢出。将您的 while 块更改为

while (!e.isCancelled()) {
    if (current < 0) {
        e.complete();
    } else {
        e.next(current);
        current *= 2;
    }
}