我是React式编程的新手，我有一段代码，只有在并行任务结束后才应该并行运行，然后才应该执行

//step 1 parallel stuff
Flux.fromIterable( sourceOneMap.keySet() )
.parallel()
.runOn( Schedulers.parallel() )
.subscribe( compId -> {
 Mono.just( compId )
.then( checkIfSystemTwoContainsSystemOneInfo(compId,sourceOneMap,sourceTwoMap,new Timestamp( new Date().getTime() )) )
.doOnError( e -> log.info( "error {}",  e.getStackTrace()) );} );
 //step 2
 return new MissingCountResult( rtbmDao.findCount(), new Date() );

现在，当我运行我的代码时，步骤2先执行，然后是步骤1。步骤2依赖于步骤1。步骤1应该先竞争。有没有办法阻止步骤2，直到步骤1结束。