Reactor系列(五)map映射
2019-12-14 16:26
1316 查看
【推荐】2019 Java 开发者跳槽指南.pdf(吐血整理) >>>
#java# #reactor# #flux# #map# #映射#
视频解视: https://www.bilibili.com/video/av79179444/
FluxMonoTestCase.java
package com.example.reactor; import lombok.Data; import lombok.ToString; import lombok.extern.slf4j.Slf4j; import org.junit.jupiter.api.Test; import reactor.core.publisher.Flux; @Slf4j public class FluxMonoTestCase extends BaseTestCase { @Test public void map() { Flux<Employee> employeeFlux = Flux.fromIterable(list); employeeFlux.filter(employee -> employee.getSalary() == 2000) .map(employee -> { Leader leader = new Leader(); leader.setName(employee.getName()); leader.setSalary(employee.getSalary()); return leader; }).log().subscribe(); employeeFlux.map((in) -> { Leader leader = new Leader(); leader.setName(in.getName()); leader.setSalary(in.getSalary()); return leader; }); } @Data @ToString class Leader { private String name; private double salary; } }
BaseTestCase.java
package com.example.reactor; import java.util.Arrays; import java.util.List; public class BaseTestCase { protected static final List<Employee> list = Arrays.asList( new Employee(1, "Alex", 1000), new Employee(2, "Michael", 2000), new Employee(3, "Jack", 1500), new Employee(4, "Owen", 1500), new Employee(5, "Denny", 2000)); }
结果:
11:37:33.668 [main] INFO reactor.Flux.MapFuseable.1 - | onSubscribe([Fuseable] FluxMapFuseable.MapFuseableSubscriber) 11:37:33.670 [main] INFO reactor.Flux.MapFuseable.1 - | request(unbounded) 11:37:33.670 [main] INFO reactor.Flux.MapFuseable.1 - | onNext(FluxMonoTestCase.Leader(name=Michael, salary=2000.0)) 11:37:33.681 [main] INFO reactor.Flux.MapFuseable.1 - | onNext(FluxMonoTestCase.Leader(name=Denny, salary=2000.0)) 11:37:33.682 [main] INFO reactor.Flux.MapFuseable.1 - | onComplete()
关注公众号,坚持每天3分钟视频学习
相关文章推荐
- Reactor系列(七)flatMap映射
- 框架学习系列 mybatis 第十八篇 高级结果一对一结果映射之resultMap的使用
- 好程序员大数据学习路线分享Scala系列之映射Map
- 深入浅出Mybatis系列(八)---mapper映射文件配置之select、resultMap
- STL系列之map(映射)
- 深入浅出Mybatis系列(八)---mapper映射文件配置之select、resultMap
- 深入浅出Mybatis系列(八)---mapper映射文件配置之select、resultMap
- 深入浅出Mybatis系列(八)---mapper映射文件配置之select、resultMap
- 深入浅出Mybatis系列(八)---mapper映射文件配置之select、resultMap
- 深入浅出Mybatis系列(八)---mapper映射文件配置之select、resultMap
- PHP转Go系列:map映射
- 深入浅出Mybatis系列(八)---mapper映射文件配置之select、resultMap
- 深入浅出Mybatis系列(八)---mapper映射文件配置之select、resultMap
- 深入浅出Mybatis系列(八)---mapper映射文件配置之select、resultMap
- 深入浅出Mybatis系列(八)---mapper映射文件配置之select、resultMap
- scala编程系列(5)-scala集set和映射map
- 深入浅出Mybatis系列(八)---mapper映射文件配置之select、resultMap
- iBatis.Net系列(五) ParameterMap
- 关联容器map的下标操作(特殊)---map的本质就是关联数组, 数组的本质就是映射!
- Python数据结构:映射(map)——字典