Dart流多次调用first属性报错：Stream已被监听

核心原因：单订阅流的特性 #

默认StreamController创建的是单订阅流，这类流的核心规则是：只能被监听一次——无论订阅是否主动取消，流的内部状态会被标记为“已监听”，后续任何尝试再次监听的操作（包括调用stream.first）都会抛出Bad state: Stream has already been listened to错误。

stream.first的工作逻辑是创建一个订阅，获取流的第一个元素后立即取消订阅，但这只是终止了当前订阅，并没有重置流的“已监听”状态，所以第二次调用时触发错误。

关于广播流（Broadcast Stream）的误解 #

你尝试使用.broadcast()创建广播流仍出现异常，是因为广播流不缓存历史事件：

• 你的代码中先调用ctrl.add(1)再执行ctrl.stream.first，此时订阅行为发生在事件发送之后，广播流无法捕获已发送的事件，导致第一次first会一直处于等待状态，并非真正的“二次调用报错”。
• 若调整顺序，先订阅再发送事件，广播流支持多次监听：

import 'dart:async';

void main() async {
  final ctrl = StreamController<int>.broadcast();

  // 先订阅再发送事件
  final i1 = await ctrl.stream.first; 
  print(i1.toString()); // 输出1

  final i2 = await ctrl.stream.first; 
  print(i2.toString()); // 输出2

  ctrl.add(1);
  ctrl.add(2);
}

解决方法 #

根据业务场景，可选择以下方案：

方案1：每次监听时转换为广播流 #

通过asBroadcastStream()将单订阅流临时转为广播流，实现多次调用first：

import 'dart:async';

void main() async {
  final ctrl = StreamController<int>();

  ctrl.add(1);
  final i1 = await ctrl.stream.asBroadcastStream().first; 
  print(i1.toString()); // 输出1

  ctrl.add(2);
  final i2 = await ctrl.stream.asBroadcastStream().first; 
  print(i2.toString()); // 输出2
}

方案2：自定义广播流缓存历史事件 #

如果需要捕获订阅前发送的事件，可以在广播流的onListen回调中重发历史数据：

import 'dart:async';

void main() async {
  final List<int> eventHistory = [];
  final ctrl = StreamController<int>.broadcast(
    onListen: () {
      // 订阅时重发所有历史事件
      for (var event in eventHistory) {
        ctrl.add(event);
      }
    },
  );

  ctrl.add(1);
  eventHistory.add(1);
  final i1 = await ctrl.stream.first; 
  print(i1.toString()); // 输出1

  ctrl.add(2);
  eventHistory.add(2);
  final i2 = await ctrl.stream.first; 
  print(i2.toString()); // 输出2
}

方案3：使用RxDart的BehaviorSubject #

如果依赖RxDart库，BehaviorSubject会自动缓存最新事件，无论订阅在事件发送前还是后，都能获取到最新值：

import 'package:rxdart/rxdart.dart';

void main() async {
  final subject = BehaviorSubject<int>();

  subject.add(1);
  final i1 = await subject.first; 
  print(i1.toString()); // 输出1

  subject.add(2);
  final i2 = await subject.first; 
  print(i2.toString()); // 输出2
}

内容的提问来源于stack exchange，提问作者Marco Di Benedetto