首页 ❯

如何将单<列表<弦>>转换为通量<字符串>

java project-reactor
2022-09-01 03:32:02

我正在将用RxJava 1.x编写的小项目转换为Reacter 3.x。一切都很好，除了我不知道如何用合适的对应物替换。我有，我需要将其转换为.flatMap(Observable::from)Mono<List<String>>Flux<String>


答案 1

在 Reactor 3 中，运算符已专门化为几个变体，具体取决于原始源（数组、可迭代等）。from

适用于您的情况。yourMono.flatMapMany(Flux::fromIterable)


答案 2

我认为静态工厂可能更适合这里：Flux::mergeSequential

 Iterable<Mono<String>> monos = ...
 Flux<String> f = Flux.mergeSequential(monos);

这种合并（顺序）将保持给定源可迭代内部的顺序，并且还将从所有参与源热切地订阅/请求（因此在计算单声道结果时需要更多的并行化）。


推荐
更多 »
标签
更多 »
php pass-by-reference optional-parameters default-value javascript arrays dom function string object serialization tostring visibility syntax jslint use-strict operators equality equality-operator identity-operator datetime timestamp date-arithmetic redirect angularjs loops foreach iteration scope variables
推荐
更多 »