FluxSingleTest.java

@Slf4j
public class FluxPublishTest {

    @Test
    public void test() {

        Scheduler scheduler = Schedulers.single();

        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());

    }

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

13:42:36.356 [main] DEBUG reactor.util.Loggers$LoggerFactory - Using Slf4j logging framework
13:42:36.447 [single-1] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 1
13:42:36.447 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest -  Thread Done: main
13:42:36.448 [single-1] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 1
13:42:36.448 [single-1] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 2
13:42:36.450 [single-1] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 2
13:42:36.450 [single-1] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 3
13:42:36.451 [single-1] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 3
13:42:36.451 [single-1] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 4
13:42:36.451 [single-1] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 4
13:42:36.451 [single-1] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 5
13:42:36.451 [single-1] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 5
13:42:36.451 [single-1] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 6
13:42:36.451 [single-1] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done: 6