java 如何将Flux〈List>扁平< T>化为Flux< T>？

rkue9o1l 于 2023-01-24 发布在 Java

关注(0)|答案(2)|浏览(355)

我的代码看起来像这样：

fun mapBatch(batch: List<String>): Mono<List<MyClass>> ...

fun myFun(stream: Flux<String>): Flux<MyClass> {
    return stream
            .bufferTimeout(50, Duration.ofSeconds(60L))
            .flatMap{ batch -> mapBatch(batch) }
            /// now here I would like to get Flux<MyClass> but have Flux<List<MyClass>> 
}

如何从Flux<List<T>>获取Flux<T>？

Java

来源：https://stackoverflow.com/questions/67972425/how-to-flatten-fluxlistt-to-fluxt

2条答案

按热度按时间

qltillow1#

您应该使用.concatMapIterable或.flatMapIterable。
Flux#flatMapIterable是一个特殊的运算符，用于将表示为Iterable的项“扁平化”为T的React流。

赞(0）回复(0）举报 2023-01-24

0sgqnhkj2#

可以使用flatMap(Flux::fromIterable)将其展平：

fun mapBatch(batch: List<String>): Mono<List<MyClass>> ...

fun myFun(stream: Flux<String>): Flux<MyClass> {
    return stream
            .bufferTimeout(50, Duration.ofSeconds(60L))
            .flatMap{ batch -> mapBatch(batch) }
            .flatMap(Flux::fromIterable) 
}

赞(0）回复(0）举报 2023-01-24

我来回答

java 如何将Flux〈List>扁平< T>化为Flux< T>？

2条答案

相关问题

热门标签

最新问答