如何让Flux.buffer(Publisher)支持输出空缓冲区？

场景与问题 #

需要实现基于snapshotTriggerFlux触发eventFlux的缓冲区快照输出，核心要求是即便eventFlux没有任何事件产生，后续绑定的someProcedure也必须执行。

现有实现代码如下：

Flux<Integer> snapshotTriggerFlux = ...;
Flux<SomeEvent> eventFlux = ...;

Flux.zip(
    eventFlux.buffer(snapshotTriggerFlux), // 期望获取缓冲区快照
    someOtherPublishers
)
 .doOnNext(someProcedure)

当前遇到的问题：当eventFlux无事件输出时，buffer(Publisher)方法会自动丢弃空缓冲区，导致Flux.zip没有数据输出，最终someProcedure无法被触发执行。

已尝试方案的局限 #

• Flux.buffer(Publisher)：查看源码确认该方法逻辑会丢弃空缓冲区，无法满足需求。
• Flux.bufferWhen：从功能上看似适配，但存在数据丢失的潜在风险，且同步逻辑难以正确实现。
• 合并triggerFlux与eventFlux后使用bufferUntil：会引入额外的类型处理复杂度，增加代码维护成本。

后续处理建议 #

如果暂时没有更简洁的内置解决方案，可以考虑自行封装自定义操作符；或者直接向Project Reactor团队提交Feature Request，建议新增Flux.buffer(Publisher other, boolean emitEmptyBuffers)方法，通过参数配置是否允许输出空缓冲区。

内容的提问来源于stack exchange，提问作者Martin Heyer