标签：java spring kotlin spring-webflux project-reactor

我在我的Webflux控制器中使用Monos和ResponseEntitys来操纵标头和其他响应信息.例如：

@GetMapping("/{userId}")
fun getOneUser(@PathVariable userId: UserId): Mono<ResponseEntity<UserDto>> {
    return repository.findById(userId)
        .map(User::asDto)
        .map { ResponseEntity.ok(it) }
        .defaultIfEmpty(ResponseEntity.notFound().build())
}

@GetMapping
fun getAllUsers(): Flux<UserDto> {
    return repository.findAllActive().map(User::asDto)
}

两者都工作正常,但有些情况下需要将ResponseEntity与Flux结合使用.响应类型应该是什么？使用ResponseEntity< Flux< T>>？是否正确？

例如：

@GetMapping("/{userId}/options")
fun getAllUserOptions(@PathVariable userId: UserId): ??? {
    return repository.findById(userId)
        .flatMapIterable{ it.options }
        .map { OptionDto.from(it) }
        // if findById -> empty Mono then:
        //   return ResponseEntity.notFound().build() ?
        // else:
        //   return the result of `.map { OptionDto.from(it) }` ?
}

我想在这里实现的行为是,如果repository.findById(userId)是一个空的Mono,则getAllUserOptions返回404,否则返回user.options作为Flux.

更新：
这里的存储库是ReactiveCrudRepository

解决方法:

如果用户不存在,请使用switchIfEmpty抛出异常：

return repository
    .findById(userId)
    .switchIfEmpty(Mono.error(NotFoundException("User not found")))
    .flatMapIterable{ it.options }
    .map { OptionDto.from(it) }

然后使用exception handler将其转换为404响应.

标签：java,spring,kotlin,spring-webflux,project-reactor
来源： https://codeday.me/bug/20190622/1261806.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。