是否建议将 Arraylist 转换为 Reactor 的 flux 来处理数据？

Question

我的一位同事对我说，与其处理流，不如创建一个 Flux，而不是按原样使用 List，然后将我的数据处理给它。

但这对我来说没有意义，因为我认为反应流通常对阻塞 io 而不是数据处理很有用。

有人可以验证我同事建议的新方法是否正确吗？ 如果它是正确的，它比我以前的方法有什么优势（性能方面）

//Model
rootObject{
List<rootNodes> rootNodes
}

//My current code 
MonoOfRootObject.map( rootobject.getrootnodes.stream()
.(..do some filtering and replacement..) )


//Proposed code according to my colleague
MonoOfRootObject.map( Flux.fromIterable(rootobject.getrootnodes)
.(..do some filtering and replacement..) )

请帮助我对 Reactor（或一般的函数式编程）有点陌生

谢谢

Answer 1

是的，你是对的。当您需要处理异步数据时，Reactor 和 Reactive Streams 通常很有用 and/or 并发。

要在内存列表上进行常规过滤和转换，Java Stream 完全没问题，使用 Reactive Stream 就太过分了（而且可能在性能方面也有开销）。