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