Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- @Slf4j
- public class FluxPublishTest {
- @Test
- public void test() {
- Scheduler scheduler = Schedulers.immediate();
- Flux.range(1, 5)
- .map(n -> Mono.just(n).publishOn(scheduler).map(k -> process(k))
- .thenEmpty(m -> log.info("Job Done")).subscribe()).subscribe();
- }
- public Mono<Object> process(Object n) {
- log.info("Processing : {}", n);
- return Mono.empty();
- }
- }
- 15:21:22.753 [main] DEBUG reactor.util.Loggers$LoggerFactory - Using Slf4j logging framework
- 15:21:22.906 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 1
- 15:21:22.909 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done
- 15:21:22.910 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 2
- 15:21:22.910 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done
- 15:21:22.910 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 3
- 15:21:22.910 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done
- 15:21:22.912 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 4
- 15:21:22.912 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done
- 15:21:22.912 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Processing : 5
- 15:21:22.912 [main] INFO com.capitalone.fs.marketingone.FluxPublishTest - Job Done
Add Comment
Please, Sign In to add comment