反应堆核心编译问题

Question

我对 Reactor-core 还很陌生，我正在尝试了解它的工作方式。我找到了一个我正在尝试运行的示例程序，但它给了我如下错误。

详情 -> Flux 类型中的方法 subscribe(Consumer super Integer>) 不适用于参数（new Flow.Subscriber(){}）

据我了解，它需要一个订阅者实现来创建订阅，以便从通量中获取数据。

请帮忙。

我在 JDK 8 和 JDK 11 中执行了它，但是两个 JDK 都出现了同样的错误。

    public static void callCustomSubscribe() {
        List<Integer> elements = new ArrayList<Integer>();
        
//      Subscriber<Integer> subs = new SubscribeImpl();

        Flux.just(1, 2, 3, 4)
          .log()
          .subscribe(new Subscriber<Integer>() { // Error comes here
            @Override
            public void onNext(Integer integer) {
              elements.add(integer);
            }

            @Override
            public void onError(Throwable t) {}

            @Override
            public void onComplete() {}

            @Override
            public void onSubscribe(Subscription subscription) {
                // TODO Auto-generated method stub
                subscription.request(Long.MAX_VALUE);
            }
        });
    }

Answer 1

不，它不需要自定义Subscriber 实现来运行。 Reactor 中已经实现了几个。

我真的不明白你想用你的代码做什么。但是您通常不会声明外部 ArrayList 并在 lambdas 中使用它。它更像是你在 lambdas 中进行转换的 java 流。

示例：

Flux.just(1, 2, 3, 4)
    .map(value -> {
        return value += 1;
    })
    .subscribe(n -> {
        System.out.println(n);
    });

我开始了解reactor 的好方法是阅读reactor 文档的开头。 Simple ways to create a Flux or Mono and Subscribe to it.

您的错误是因为您使用的是Flow.Subscriber，而它真正想要的是Consumer，这是一个完全不同的界面。如果你真的想实现一个完整的订阅者，一个好的开始是使用 BaseSubscriber 作为抽象基础，然后覆盖其中的一些功能，但这更多的是中间练习。