java - 创建保持原始顺序的单声道数组对象

Question

我需要实现返回 Mono< Array< ProcessedObject>> 的函数。作为参数，它采用对象列表并使用返回 Mono<ProcessedObject> 的函数处理它们。函数需要保持原始顺序，这意味着返回列表中的第一个元素必须从参数列表中的第一个元素创建。到目前为止，我有以下解决方案，但它没有保持所需的顺序。Flux 甚至有可能吗？

       private fun createItems(objects: List<Someobjects>): Mono<Array<ProcessedObject>> {
         return Flux.fromIterable(objects)
           .flatMap {
             processObject(it)
           }.collectList().map { it.toTypedArray() }
}

编辑：澄清一点 processObject 返回 Mono< ProcessedObject>

标签： javakotlinreactor

Answer 1

您可以尝试使用concatMap而不是flatMap.

这是Docu https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#concatMap-java.util.function.Function-的链接

private fun createItems(objects: List<Someobjects>): Mono<Array<ProcessedObject> {
         return Flux.fromIterable(objects)
           .concatMap {
             processObject(it)
           }.collectList().map { it.toTypedArray() }
}

flatMap 和 concatMap 的区别在于后者保留了原来的顺序。