Flutter StreamController数据获取异常及类型不匹配问题求助

错误核心是你误将localJoined这个Stream实例当作bool值传入Map，而代码期望的是流中发射的bool类型数据，因此触发了类型不匹配报错。

根据业务场景，提供三种正确获取流中值的方式：

1. 实时监听流变化并发送数据 #

如果localJoined的值会动态更新，需要实时响应并同步到remoteStream：

userJoined: (int uid, int elapsed) {
  print('++@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ remote user $uid joined channel');
  
  // 监听localJoined流，每次值更新时发送到remoteStream
  localJoined.listen((localJoinedValue) {
    print('++@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ Value from localJoined: $localJoinedValue');
    remoteStreamController.sink.add({
      "engine": engine,
      "localJoined": localJoinedValue, // 传入流的实际值而非Stream对象
      "remoteId": uid
    });
  });
}

2. 异步获取流的最后一个值 #

如果只需要localJoined当前的最新值，可通过last属性（异步操作，需配合async/await）：

userJoined: (int uid, int elapsed) async {
  print('++@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ remote user $uid joined channel');
  
  try {
    // 等待获取流的最后一个有效值
    final localJoinedValue = await localJoined.last;
    print('++@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ Value from localJoined: $localJoinedValue');
    
    remoteStreamController.sink.add({
      "engine": engine,
      "localJoined": localJoinedValue,
      "remoteId": uid
    });
  } catch (e) {
    print('获取localJoined值失败: $e');
  }
}

3. 保存流的最新值到变量（频繁访问推荐） #

如果需要多次访问localJoined的当前值，可维护一个变量存储最新数据，避免重复监听：

// 在类内部定义变量保存最新值
dynamic _latestLocalJoinedValue;

// 初始化时监听流并更新变量
void initStreamListener() {
  localJoined.listen((value) {
    _latestLocalJoinedValue = value;
  });
}

// 在userJoined回调中使用
userJoined: (int uid, int elapsed) {
  print('++@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ remote user $uid joined channel');
  
  if (_latestLocalJoinedValue != null) {
    remoteStreamController.sink.add({
      "engine": engine,
      "localJoined": _latestLocalJoinedValue,
      "remoteId": uid
    });
  } else {
    print('localJoined还未发射任何数据');
  }
}

如果确定localJoined流发射的是bool类型，建议将Stream泛型从dynamic改为bool，提前做类型校验：

final localStreamController = StreamController<bool>.broadcast();
Stream<bool> get localJoined => localStreamController.stream.asBroadcastStream();

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