Spring反应式编程:如何创建一个动态的Publishers列表作为Flux.merge的输入。

我是Spring Reactive编程的新手,我正在开发一个返回Flux的REST端点。 比如说,我在开发一个返回Flux的REST端点。

 @PostMapping
 public Flux<MyResponse> processRequests(@RequestBody List<MyRequest> requests) {

        return Flux.merge(Arrays.asList(dataSource.processRequest(requests.get(0)), dataSource2.processRequest(requests.get(0)))).parallel()
                    .runOn(Schedulers.elastic()).sequential();
}

示例代码中的每个数据souce(dataSource和dataSource2)都实现了一个像这样的接口。

public interface MyResponseAdapter {
    Flux<MyResponse> processRequest(MyRequest request);
}

这段代码工作得很好,它按照预期返回了Flux,但正如你所看到的,这段代码只引用了MyRequest列表中的第一个元素。 我需要做的是为MyRequest列表中的每个元素构造Flux.merge。 谁能给我指出正确的方向?

解决方案:

我想我已经找到了一个简单的解决方案。

        List<Flux<MyResponse>> results = new ArrayList<>();
        for (MyRequest myRequest : requests ) {
            results.add(dataSource.processRequest(myRequest));
            results.add(dataSource2.processRequest(myRequest));
        }

        return Flux.merge(results).parallel().runOn(Schedulers.elastic()).sequential();

本文来自投稿,不代表运维实战侠立场,如若转载,请注明出处:https://www.shizhanxia.com/379.html

(0)
上一篇 2022年6月29日 下午3:55
下一篇 2022年6月29日 下午3:56

相关推荐

发表评论

登录后才能评论