如何采用响应式方式重写无返回值的多次触发型简单回调？

好问题！其实你想要的多次触发的无值通知，在Rx、Flow、LiveData这些响应式库中都有更优雅的实现方式，只是这类需求的语义容易被忽略。下面分库给你拆解：

RxJava（Java/Kotlin） #

RxJava的Completable确实只适合单次完成的操作，但要实现多次通知，有两个优雅的选择：

• Kotlin环境下用Observable<Unit>/Flowable<Unit>：Unit是Kotlin专门设计的“无返回值”类型，本身是单例，语义非常清晰。发射事件时只需要调用emitter.onNext(Unit)即可，完全不需要额外的无意义对象。
• Java环境下自定义单例枚举：因为Java没有Unit，可以定义一个语义明确的枚举类来承载事件，比如：

  enum UpdateTrigger { INSTANCE }
  
  // 用法示例
  Observable<UpdateTrigger> createUpdateObservable() {
      return Observable.create(emitter -> {
          // 每次需要触发回调时
          emitter.onNext(UpdateTrigger.INSTANCE);
      });
  }
  

  枚举的单例特性保证了不会产生额外的对象开销，同时语义明确，比Object或空字符串好太多。

注意：RxJava 2及以后版本不允许发射null，所以不要尝试用Observable<Void>并发射null，这会直接抛出异常。

Kotlin Flow #

Flow对这种需求的支持堪称完美，直接使用Flow<Unit>即可：

fun createUpdateFlow(): Flow<Unit> = flow {
    // 每次需要触发通知时
    emit(Unit)
}

Unit的语义完全匹配“无值但有事件发生”的场景，代码简洁且意图明确，是Kotlin环境下的最优解。

LiveData #

LiveData同样可以利用Unit（Kotlin）或自定义单例（Java）来实现：

• Kotlin环境：

  val updateLiveData = MutableLiveData<Unit>()
  
  // 触发通知
  updateLiveData.postValue(Unit)
  
  // 观察通知
  updateLiveData.observe(this) {
      // 执行你的void回调逻辑
      updated()
  }
  

• Java环境：可以用自定义枚举或者LiveData<Void>（注意postValue(null)是允许的，LiveData支持发射null）：

  MutableLiveData<Void> updateLiveData = new MutableLiveData<>();
  
  // 触发通知
  updateLiveData.postValue(null);
  
  // 观察通知
  updateLiveData.observe(this, unused -> {
      updated();
  });
  

为什么响应式库都要求泛型？ #

你提到的点非常关键：响应式库的核心是数据流，即使是无值的通知，本质上也是一个“事件发生”的信号。用一个语义明确的类型（比如Unit、自定义枚举）来承载这个信号，是符合响应式设计思想的——数据流中的每个元素都应该有清晰的意义，而不是用无意义的空值或对象来滥竽充数。

你之前想到的Observable<Object>或Event对象思路是对的，只是可以优化成更语义化的类型，这样代码可读性和维护性都会更好。

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