学习如何转换异步数据
描述
Reactor 附带多个可用于转换数据的操作符。
public class Part04Transform {//========================================================================================// TODO Capitalize the user username, firstname and lastnamepublic Mono<User> capitalizeOne(Mono<User> mono) {return mono.map(user -> new User(user.getUsername().toUpperCase(), user.getFirstname().toUpperCase(), user.getLastname().toUpperCase()));}//========================================================================================// TODO Capitalize the users username, firstName and lastNamepublic Flux<User> capitalizeMany(Flux<User> flux) {return flux.map(user -> new User(user.getUsername().toUpperCase(), user.getFirstname().toUpperCase(), user.getLastname().toUpperCase()));}//========================================================================================// TODO Capitalize the users username, firstName and lastName using #asyncCapitalizeUserpublic Flux<User> asyncCapitalizeMany(Flux<User> flux) {return flux.flatMap(this::asyncCapitalizeUser);}Mono<User> asyncCapitalizeUser(User u) {return Mono.just(new User(u.getUsername().toUpperCase(), u.getFirstname().toUpperCase(), u.getLastname().toUpperCase()));}
}