如何用Project Reactor创建无具体值的事件流/发布者？

其实你完全不用折腾虚拟对象来凑数！咱们在Project Reactor里有更优雅的方式实现“只发事件、不带具体值”的流，我给你梳理两种常用方案：

1. 正确利用Flux<Void>（你的初始思路没毛病，只是对它的理解有偏差） #

你之前误以为Flux<Void>是空流，其实它的语义是**“只关心事件发生的时机，不关心事件携带的内容”**。因为Void类型没有实例，所以我们用null来代表事件信号（Reactor完全允许这种用法）。

针对你的场景，完全可以把原Flux<Path>转换成Flux<Void>，再添加初始事件：

// 把文件系统变更流转换成无值事件流
Flux<Void> fsEvents = getFilesystemChanges()
    .map(path -> null); // 忽略Path值，只保留事件触发时机

// 添加启动时的初始事件，再对接后续操作
Flux<Void> events = fsEvents
    .startWith(Flux.just(null)); // 用null表示初始事件

// 后续操作完全不用管值，因为我们本来就不需要它
events.map(v -> 42)
    .subscribe(result -> {
        // 这里的result是42，但你可以直接执行逻辑，不用关心来源
        System.out.println("事件触发，执行后续逻辑");
    });

如果只是需要定时触发无值事件，还可以直接创建这样的流：

// 每秒发送一次无值事件
Flux<Void> ticker = Flux.interval(Duration.ofSeconds(1))
    .map(tick -> null);

2. 用Mono.fromRunnable或Flux.fromRunnable（更侧重“执行动作”的场景） #

如果你的核心需求是“事件触发时执行某个动作，完全不需要传递任何数据”，可以把每个事件转换成无返回值的动作：

Flux<Void> fsEvents = getFilesystemChanges()
    .flatMap(path -> Mono.fromRunnable(() -> {
        // 这里可以执行你需要的前置动作，比如日志、状态更新
        System.out.println("文件系统有变更，但我不需要具体路径");
    }));

// 同样可以添加初始动作
Flux<Void> events = fsEvents
    .startWith(Mono.fromRunnable(() -> System.out.println("初始化事件触发")));

小提醒 #

• 不用再创建虚拟Path对象了，上述两种方式都是Reactor社区约定俗成的无值事件流实现方式
• Flux<Void>的onNext信号携带null是完全合法的，社区普遍用它来表示“无内容的事件触发”

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