是否建议将 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 通常很有用。要在内存列表上进行常规过滤和转换，Java Stream 完全没问题，而使用 Reactive Stream 就太过分了（而且可能在性能方面也有开销）。