Dart/Flutter 中如何判断活跃 Stream 是否已被监听？

核心实现方式 #

Dart SDK 原生Stream类内置了只读属性hasListener，可直接用于判断当前Stream是否存在正在生效的监听订阅。

不同Stream类型的使用注意 #

• 单订阅Stream（默认类型）：默认仅允许存在1个活跃订阅，当hasListener为true时再次调用listen()会直接抛出异常。即使后续取消订阅使hasListener回到false，该单订阅Stream也无法被再次监听，需要重新生成新的Stream实例才能使用。
• 广播Stream：支持同时存在多个活跃订阅，只要当前至少存在1个未取消的订阅，hasListener就返回true，多订阅之间互不冲突。

代码示例 #

import 'dart:async';

void main() {
  // 适配多页面监听场景，创建广播类型StreamController
  final StreamController<int> counterController = StreamController<int>.broadcast();
  final Stream<int> counterStream = counterController.stream;

  // 校验监听状态的方法
  void checkListenerStatus() {
    if (counterStream.hasListener) {
      print('Stream当前存在活跃监听');
    } else {
      print('Stream当前无活跃监听');
    }
  }

  // 测试逻辑
  checkListenerStatus(); // 输出：Stream当前无活跃监听

  // 页面1订阅
  StreamSubscription sub1 = counterStream.listen((val) => print('页面1收到值：$val'));
  checkListenerStatus(); // 输出：Stream当前存在活跃监听

  // 页面2订阅（广播Stream支持多订阅，无报错）
  StreamSubscription sub2 = counterStream.listen((val) => print('页面2收到值：$val'));
  checkListenerStatus(); // 输出：Stream当前存在活跃监听

  // 发送事件测试
  counterController.add(1);
  // 输出：
  // 页面1收到值：1
  // 页面2收到值：1

  // 取消所有订阅
  sub1.cancel();
  sub2.cancel();
  checkListenerStatus(); // 输出：Stream当前无活跃监听
}

场景适配建议 #

你的需求是多页面同时监听同一个Stream，直接使用广播类型的Stream即可，无需额外拦截重复监听逻辑。如果现有Stream是默认单订阅类型，可调用asBroadcastStream()方法将其转为广播Stream后再使用。

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