Webflux Reactor como mesclar a saída Stream.map, que pode ser Mono e Flux no Flux

Aé usado para obter fonte. Na mapfunção a seguir, source é a Fluxif apossui source caso contrário source é a Mono. A função retorna todas as fontes que podem ser consultadas com base na Lista de A, o tamanho da lista pode ser 1. A questão é como lidar com este Mono e Flux combinados com Flux, quando a saída Stream.map pode ser um dos dois.

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;
}