江苏龙网

  1. 主页 > 生活百科 > >

新一代WebFlux框架核心技术Reactor响应式编程基本用法( 三 )

框架

Flux.just(1, 3, 6).flatMap(id -> {Mono<Integer> query = Mono.fromSupplier(() -> {System.out.println("查询数据...") ;return id * 10 ;}).delayElement(Duration.ofSeconds(2)) ;Mono<String> save = Mono.fromSupplier(() -> {System.out.println("保存数据...") ;return "success - " + id ;}) ;return Mono.when(query, save) ;}).doOnComplete(() -> {System.out.println("执行完成...") ;}).subscribe() ;

新一代WebFlux框架核心技术Reactor响应式编程基本用法

文章插图
图片
  • filterWhen操作符
Flux.just(1,2,3,4,5,6).concatMap(item -> Mono.just(item).filterWhen(r -> {return Mono.just(r % 2 == 0) ;})).subscribe(System.out::println) ;
新一代WebFlux框架核心技术Reactor响应式编程基本用法

文章插图
总之，Reactor中的Flux和Mono是响应式编程的核心组件，它们提供了丰富的操作符和方法来处理异步数据流 。因此，对于使用WebFlux的开发者来说 ， 掌握Reactor的使用是非常重要的 。
完毕?。。?




推荐阅读


上一篇：HTTP 和 HTTPS 之间除了安全性区别外，还有哪些区别

下一篇：Springboot扩展点之BeanDefinitionRegistryPostProcessor，你学会了吗？