FluxParallelTest.java

@Slf4j
public class FluxPublishTest {

    @Test
    public void test() {

        Scheduler scheduler = Schedulers.newParallel("P");

        Flux.range(1, 6)
                .parallel()
                .runOn(scheduler)
                .map(p -> {
                    process(p);
                    log.info("Job Done: {}", p);
                    return p;
                })
                .sequential()
                .subscribe();


        log.info(" Thread Done: {}", Thread.currentThread().getName());


        Scheduler scheduler1 = Schedulers.immediate();

        Flux.range(1, 5)
                .map(n -> Mono.just(n).subscribeOn(scheduler1).map(k -> process(k))
                        .thenEmpty(m -> log.info("Job Done")).subscribe()).subscribe();


    }

    public int process(Integer n) {
        log.info("Processing : {}", n);
        return n;
    }
}

13:37:43.106 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest -  Thread Done: main

13:37:43.105 [P-1] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 1
13:37:43.105 [P-3] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 3
13:37:43.105 [P-2] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 2
13:37:43.105 [P-5] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 5
13:37:43.107 [P-6] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 6
13:37:43.105 [P-4] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 4
  
13:37:43.108 [P-2] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 2
13:37:43.108 [P-6] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 6
13:37:43.108 [P-5] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 5
13:37:43.108 [P-4] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 4
13:37:43.108 [P-1] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 1
13:37:43.108 [P-3] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 3
  
13:37:43.133 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 1
13:37:43.134 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done
13:37:43.134 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 2
13:37:43.134 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done
13:37:43.134 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 3
13:37:43.134 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done
13:37:43.134 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 4
13:37:43.134 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done
13:37:43.134 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 5
13:37:43.134 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done