主页 / coding / 问题 / 76926036
Accepted
Tiina
Asked: 2023-08-18 10:05:07 +0800 CST

Webflux Reactor如何合并Stream.map输出，可以是Mono和Flux成Flux

  • 772

A用于获取源码。在下面的函数中，如果拥有map源，则源是一个，否则源是一个。函数返回基于A的List可以查询的所有源，列表大小可以是1。问题是当Stream.map输出可以是两者之一时，如何处理这个Mono和Flux组合成Flux。FluxaMono

class A {
    String x;
    String y;
    boolean isOwner();
}

Flux<Source> foo(List<A> a) {
  Flux<Source> sources = a.stream().map(v -> if (v.isOwner) {
        Flux<Source> ownedSource = ...; return ownedSource;
      } else {
        Mono<Source> givenSource = ...; return givenSource;
      }
    }.???
  return sources;
}
spring-webflux

1 个回答

  1. Best Answer

    您可以将它用作Fluxwith flatMap：

    Flux<Source> foo(List<A> a) {
  Flux<Source> sources = Flux.fromIterable(a)
    .flatMap(v -> if (v.isOwner) {
        Flux<Source> ownedSource = ...; return ownedSource;
      } else {
        Mono<Source> givenSource = ...; return givenSource;
      }
    }
  return sources;
}
    • 1

相关问题