Reactor系列(十八)merge合并

java#reactor#flux#merge

合并

视频讲解: https://www.bilibili.com/vide...

FluxMonoTestCase.java

package com.example.reactor;

import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.Test;
import reactor.core.publisher.Flux;

import java.time.Duration;

@Slf4j
public class FluxMonoTestCase extends BaseTestCase {
    @Test
    public void merge() throws InterruptedException {
        Flux<Long> longFlux = Flux.interval(Duration.ofMillis(100)).take(10);
        Flux<Long> longFlux2 = Flux.interval(Duration.ofMillis(100)).take(10);
        Flux<Long> longFlux3 = Flux.merge(longFlux,longFlux2);
        longFlux3.subscribe(val ->log.info("->{}",val));
        Thread.sleep(2000);
    }

}

结果:

5:49:21.503 [main] DEBUG reactor.util.Loggers$LoggerFactory - Using Slf4j logging framework
15:49:21.657 [parallel-1] INFO com.example.reactor.FluxMonoTestCase - ->0
15:49:21.657 [parallel-2] INFO com.example.reactor.FluxMonoTestCase - ->0
15:49:21.757 [parallel-1] INFO com.example.reactor.FluxMonoTestCase - ->1
15:49:21.757 [parallel-1] INFO com.example.reactor.FluxMonoTestCase - ->1
15:49:21.844 [parallel-2] INFO com.example.reactor.FluxMonoTestCase - ->2
15:49:21.845 [parallel-1] INFO com.example.reactor.FluxMonoTestCase - ->2
15:49:21.957 [parallel-1] INFO com.example.reactor.FluxMonoTestCase - ->3
15:49:21.957 [parallel-1] INFO com.example.reactor.FluxMonoTestCase - ->3
15:49:22.057 [parallel-2] INFO com.example.reactor.FluxMonoTestCase - ->4
15:49:22.057 [parallel-1] INFO com.example.reactor.FluxMonoTestCase - ->4
15:49:22.157 [parallel-2] INFO com.example.reactor.FluxMonoTestCase - ->5
15:49:22.157 [parallel-2] INFO com.example.reactor.FluxMonoTestCase - ->5
15:49:22.258 [parallel-1] INFO com.example.reactor.FluxMonoTestCase - ->6
15:49:22.258 [parallel-1] INFO com.example.reactor.FluxMonoTestCase - ->6
15:49:22.358 [parallel-2] INFO com.example.reactor.FluxMonoTestCase - ->7
15:49:22.358 [parallel-2] INFO com.example.reactor.FluxMonoTestCase - ->7
15:49:22.458 [parallel-1] INFO com.example.reactor.FluxMonoTestCase - ->8
15:49:22.458 [parallel-1] INFO com.example.reactor.FluxMonoTestCase - ->8
15:49:22.559 [parallel-2] INFO com.example.reactor.FluxMonoTestCase - ->9
15:49:22.559 [parallel-2] INFO com.example.reactor.FluxMonoTestCase - ->9

公众号，坚持天天3分钟视频学习