如何在Multi完成时将其转换为Uni<Void>?最优实现方案
Mutiny中Multi流完成后转
Uni<Void>的最优实现 你当前使用的multi.collect().asList().replaceWithVoid()虽然能正常运行,但确实存在冗余开销:该实现会将Multi流出的所有元素全部暂存在内存中聚合为List,即使你完全不需要消费这些元素,当流的数据量较大时会产生不必要的内存占用。
推荐实现
不需要做元素收集,直接调用Mutiny内置的元素忽略API即可,写法如下:
multi.ignoreItems().andContinueWithVoid()
方案优势
- 性能开销极低:收到流中元素时直接丢弃,不会做任何聚合、存储操作,内存占用为常量级,无论流的数据量多大都不会产生额外的元素存储成本
- 语义清晰:代码直接表达了「忽略所有元素,仅在流完成后触发Void信号」的逻辑,不需要额外解释为什么要先聚合为List
- 行为和原有实现完全对齐:会正常传递流的异常信号,如果Multi执行过程中报错,返回的Uni会正常接收到失败事件,不会吞掉异常。
如果使用的是较早版本的Mutiny没有andContinueWithVoid()方法,也可以用等价写法实现相同效果:
multi.discardItems().onCompletion().switchTo(Uni.createFrom().voidItem())
内容的提问来源于stack exchange,提问作者Michael
相关产品推荐
相关产品推荐

