如何基于配置Mock Akka Streams Source？解决类型不兼容问题

开发者阿泽

2026-7-1

Akka Streams 条件启用/禁用Source的类型统一方案

针对你遇到的配置化启用/禁用Source时物化值类型不匹配的问题，有两种成熟的最佳实践，可根据是否需要保留Cancellable的能力选择：

场景1：不需要使用`Cancellable`的取消能力

如果后续逻辑不需要操作tick Source返回的Cancellable，直接将两个分支的物化值统一为NotUsed即可：

val source: Source[T, NotUsed] = if (config.enableTickSource) {
  Source.tick(initialDelay, interval, tickValue)
    .mapMaterializedValue(_ => NotUsed) // 丢弃Cancellable，转为NotUsed
} else {
  Source.never[T] // 本身物化值就是NotUsed
}

这种方式最简单，完全消除类型差异，后续合并多个Source时无需额外处理。

场景2：需要保留取消能力

如果必须保留Cancellable接口（比如后续可能需要主动停止tick Source），则统一物化值类型为Cancellable，给Source.never映射一个空实现的Cancellable：

// 定义一个空的Cancellable实现，cancel方法无实际操作
val fakeCancellable = new Cancellable {
  override def cancel(): Boolean = false
  override def isCancelled: Boolean = false
}

val source: Source[T, Cancellable] = if (config.enableTickSource) {
  Source.tick(initialDelay, interval, tickValue) // 物化值为Cancellable
} else {
  Source.never[T]
    .mapMaterializedValue(_ => fakeCancellable) // 映射为假的Cancellable
}

这样两个分支类型完全一致，后续可以正常调用cancel()方法，禁用状态下调用不会产生任何副作用。