FluxElasticTest.java

@Slf4j
public class FluxPublishTest {

    @Test
    public void test() {

        Scheduler scheduler = Schedulers.elastic();

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


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

    }

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

13:46:45.251 [elastic-2] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 1
13:46:45.251 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest -  Thread Done: main
13:46:45.251 [elastic-7] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 6
13:46:45.251 [elastic-4] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 3
13:46:45.251 [elastic-3] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 2
13:46:45.253 [elastic-4] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 3
13:46:45.253 [elastic-3] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 2
13:46:45.251 [elastic-5] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 4
13:46:45.253 [elastic-6] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 5
13:46:45.254 [elastic-5] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 4
13:46:45.253 [elastic-2] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 1
13:46:45.253 [elastic-7] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 6
13:46:45.254 [elastic-6] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 5