将两个 Stream 合并为一个 Flux

Question

如何将两个流 Stream<String> 合并为 Flux？我的理解是我可能需要使用 Flux create 方法来创建它，但我不太确定：

flux1.create(sink -> {
    sink.onRequest(L -> {
        for(long l = 0; l < L; l++) {
            sink.next(..);
        }
    });
})

请帮忙。

Answer 1

将Streams 合二为一，然后调用Flux#fromStream：

Flux<String> flux = Flux.fromStream(Stream.concat(stream1, stream2));

另一种方法是使用Flux#fromStream 创建Flux，然后使用Flux#merge：

Flux<String> flux = Flux.merge(flux1, flux2);