我有一个
list.stream()
.map(element -> func());
在func()函数中使用Mono返回的结果,如何将这个由Mono<CustomObject>
对象组成的列表转换为Flux<CustomObject>
并从流中返回?
我有一个
list.stream()
.map(element -> func());
在func()函数中使用Mono返回的结果,如何将这个由Mono<CustomObject>
对象组成的列表转换为Flux<CustomObject>
并从流中返回?
List<Mono<CustomObject >> monoList = new ArrayList<>();
monoList(object);
Flux<CustomObject> flux = Flux.concat(monoList);
Flux.concat
(此处的文档)即可:var yourCode = list.stream().map(element -> func());
var whatyouWant = Flux.concat(yourCode);
List<T>
映射到 List<Mono<U>>
的操作,那么你可以将原始的 List<T>
转换为 Flux<T>
,例如。List<T> entities = ArrayList<>();
List<Mono<U>> monos = entities.map (this::operationThatReturnsMono);
List<T> entities = ArrayList<>();
Flux<U> flux = Flux.fromIterable(entities).flatMap(this::operationThatReturnsMono)