作者:百变精装绣 | 来源:互联网 | 2023-09-12 18:13
#java#reactor#flux#merge#合并视频讲解: https:www.bilibili.comvideoav81746042FluxMonoTestCase.jav
#java#reactor#flux#merge#
合并
视频讲解: https://www.bilibili.com/video/av81746042/
![技术分享图片](https://img6.php1.cn/3cdc5/a0d1/61b/7f8cb63edab1709f.jpeg)
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 lOngFlux= Flux.interval(Duration.ofMillis(100)).take(10);
Flux longFlux2 = Flux.interval(Duration.ofMillis(100)).take(10);
Flux 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分钟视频学习
![技术分享图片](https://img6.php1.cn/3cdc5/a0d1/61b/ae297451dafd2c66.jpeg)