Блог

У меня есть 2 горячих потока, которые работают параллельно, и один монофонический. Я хочу, чтобы mono всегда выполнялся после завершения обоих потоков. Я попытался объединить первый поток и моно, но моно выполняется сразу после завершения первого потока.Как мне убедиться, что mono всегда запускается после завершения обоих параллельных потоков.Ниже приведен лишь пример.

 var sourceFlux= Flux.range(1,10); var hotflux1=sourceFlux.publish().refCount(2); var firstFlux=hotflux1.map(i-gt;i*2).log("First");  //this is a io blocking call var secondFlux=hotflux1  .publishOn(Schedulers.boundedElastic()).map(i-gt;i*5).log("Second"); secondFlux.subscribe(); //  var firstMono=Flux.just(300).log("First Mono"); var concatedFlux=Flux.concat(firstFlux,firstMono); concatedFlux.subscribe();  

В реальном первый поток вызывает некоторую службу, а второй поток-вызов бд, и первый моно также является вызовом службы. Mono требует данных как от первого потока, так и от второго потока, прежде чем вызывать свою службу.