如何手动迭代Flux实现每次调用方法返回其下一个元素

该需求完全可以实现，核心是将默认冷运行的Flux转换为可多订阅共享的热序列，避免每次调用重新生成完整数据流，再搭配单次拉取元素的逻辑即可。

如果你直接使用原始冷Flux每次调用.next()，会每次重新订阅生成完整数据流，永远返回第一个元素，无法拿到后续元素，因此必须先做热序列转换。

以下是Java环境下的完整示例：

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public class StaticFluxFetcher {
    // 静态Flux定义，可替换为你的业务Flux
    private static final Flux<Integer> STATIC_BIZ_FLUX = Flux.range(1, 10)
            // replay(1)缓存最近1个未消费的元素，适配调用速度不均匀的场景
            .replay(1)
            // autoConnect()在第一次订阅时启动热序列，启动后不会因为订阅断开重启
            .autoConnect();

    /**
     * 每次调用返回Flux的下一个元素，流耗尽时返回空Mono
     */
    public static Mono<Integer> getNextElement() {
        // next()操作符会拉取流中最近的一个未消费元素
        return STATIC_BIZ_FLUX.next();
    }
}

• 调用示例：多次调用StaticFluxFetcher.getNextElement()会依次返回1、2、3...10，所有元素消费完后返回空Mono
• 热序列配置可根据业务调整：如果不需要缓存未消费元素，可将replay(1).autoConnect()替换为share()，如果需要流耗尽后下次调用自动重新生成新的Flux序列，可将autoConnect()替换为refCount(1)
• 实现天然线程安全：Reactor内置操作符已经处理了并发调用的安全问题，不需要额外加锁
• 如果需要同步返回普通Java对象，可追加.block()方法：Integer next = StaticFluxFetcher.getNextElement().block()，注意该阻塞操作禁止在Reactor的非阻塞调度线程中执行，会触发异常
• 无限流场景也可使用：只要元素生产速度和消费速度匹配，就可以持续调用拉取元素

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