有没有一种方法可以打印出一个流程中所有操作的链？

Question

给定项目Reactor的通量或Mono，有没有办法让通量或Mono打印出操作链的样子。例如，下面给出了代码。

Fulx flux = Flux.just("a","b","c")
              .map( v -> v.toUpperCase())
              .log();

有没有办法让flux打印出处理管道中链接的所有操作员的列表？一些漂亮的ascii格式文本或大理石图？

printTheFlux（通量）应该制作一个很好的打印输出，显示上面示例中所有运算符的结构。我不期望在lambda中生成代码只是一种查看哪些运算符链接在一起的方式。

Answer 1

很好的建议！

然而，等待它，我们可以有这样的东西：

    Disposable flux = Flux.just("a", "b", "c")
            .map(String::toUpperCase)
            .doOnNext(FluxUtil::print)
            .subscribe();

其中FLuxUtil::print只是一个静态方法，您可以用不同的方式编写。

以下是我的完整代码：

public class FluxUtil {

    private static String s = "";

    public static void main(String[] args) {

        Disposable flux = Flux.just("a", "b", "c")
                .map(String::toUpperCase)
                .doOnNext(FluxUtil::print)
                .subscribe();
    }

    private static Object print(Object o) {

        s = !s.isEmpty() ? s.concat("->") : s;
        s = s.concat(o.toString());
        System.out.println(s);
        return o;
    }
}

Answer 2

使用Scannable接口执行此操作有部分构建块：

public String textRepresentation(Flux<?> flux) {
    Scannable sc = Scannable.from(flux);
    //scan the last operator in the chain and ask if it knows its parents
    List<String> names = sc.parents().map(Scannable::operatorName)
                                     .collect(Collectors.toList());
    //as it traverses the chain from bottom to top, we need to reverse the order
    Collections.reverse(names);
    //need to also add the last operator
    names.add(sc.operatorName());
    return names.toString();
}

@Test
public void textRepresentationTest() {
    Flux flux = Flux.just("a","b","c")
                    .map( v -> v.toUpperCase())
                    .log();

    System.out.println(textRepresentation(flux));
}

印刷品

[map, log]

但并非所有操作符都完全支持它（例如，您可以看到，源代码并不完全支持）。