java - Flux to List 无阻塞

Question

寻找将 Flux 转换为 List<Object> .如果我使用 block() 会出错。因此，需要在不阻塞调用的情况下进行转换。

Flux.from(Collection.find())

使用响应式编程，但 graphql 期望 List<objects>并在返回 Flux 时出错。

带有 Block() 的代码

public List<Test> findAll() {
        return Flux.from(testCollection.find()).collectList().block();

}

错误:-

block()/blockFirst()/blockLast() are blocking, which is not supported in thread reactor-http-kqueue-7

在这里，我需要返回 List<Test>因为我不能发送 Flux<Test>由于某些原因。

Answer 1

正如评论中所述，你不能 . react 模式是保持流动。

所以，

Mono<GraphqlResponse> = Flux.just("A", "B" "C")
  .collectList()
  .map(this::someMethod);

GraphqlResponse someMethod(List<String> abcs) {
    return graphQl.doSomething(abcs);
}