java - 由运算符(operator)检查 Flux 流

Question

我尝试检查现有流，但到目前为止找不到特殊运算符。

Flux.just(1, 2, 3)
    // just inspect every element
    .map(e -> {
        System.out.println(e);
        return e;
    })
    .subscribe();

我正在寻找像 peek() 这样的运算符Java Streams 或 tap()在 RxJS 中。

Answer 1

正如您所评论的，doOnNext(System.out::println) 将只打印每个元素，这对于简单的用例来说可能就足够了。 (一般来说，doOnNext() 用于产生副作用，因此在这个意义上相当于 tap()。)

但是，如果调试是您的主要目的，您可能还需要查看 log()，它为您提供更多可能有用的信息(例如通知您订阅、请求等) .以及每个元素，以及它们如何结合在一起。)例如:

Flux.just(1, 2, 3)
        .log()
        .subscribe();

打印:

[ INFO] (main) | onSubscribe([Synchronous Fuseable] FluxArray.ArraySubscription)
[ INFO] (main) | request(unbounded)
[ INFO] (main) | onNext(1)
[ INFO] (main) | onNext(2)
[ INFO] (main) | onNext(3)
[ INFO] (main) | onComplete()