project-reactor - 从助焊剂转换为单声道

标签 project-reactor

如何将具有1个元素的助焊剂转换为单声道?

Flux.fromArray(arrayOf(1,2,1,1,1,2))
                .distinct()
                .take(1)


如何使它成为Mono(1)?

最佳答案

可以使用take(1)代替next()

这将通过获取第一个发出的项将Flux转换为值Mono,如果通量本身为空,则将其转换为空的Mono。

关于project-reactor - 从助焊剂转换为单声道,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42021559/

相关文章:

Spring 5 Web Reactive - Web 客户端 - 在响应流上使用 flatmap()

登录项目 react 器的生产

java - 在 java flux 中按对象属性分组

java - onErrorMap 和 onErrorContinue

reactive-programming - 使用 Mono 值并用它来调用另一个 Mono

java - Flux.generate(...) 的预加载元素

java - Mono::然后返回 null

java - 如何在 Spring 数据 r2dbc 中替换 @PrePersist

java - 如何在Reactor中使用PersistentQueue?

unit-testing - 返回Mono/Flux的Spring webflux单元测试方法