Dart Future执行卡在return语句，蓝牙通信异常排查

核心问题根源 #

你遇到的问题本质是广播流（broadcast stream）的订阅时机错误，导致首次请求的响应被丢失，进而让Future一直处于pending状态。

具体流程拆解：

1. 首次调用getConfigData时，你先发送蓝牙请求，再开始订阅流。但蓝牙模块的响应速度可能比流订阅更快，此时响应数据已经被广播流丢弃（广播流没有订阅者时会直接丢掉数据）。
2. 代码卡在await for循环里等待数据，直到第二次调用getConfigData：
   • 第二次发送请求后，首次调用的流订阅已经存在，新的响应被首次订阅捕获，才触发首次Future的返回；
   • 同时第二次的订阅又开始等待下一个响应，陷入循环。

另外，await stream.first阻塞也是同样原因：订阅前数据已经丢失，first一直在等不存在的第一个数据。

修复方案 #

方案1：调整订阅与请求的顺序（最直接）

先订阅流，再发送请求，确保不会错过响应：

Future<ConfigData?> getConfigData() async {
    var stream = listenForResponses();
    // 先订阅流，再发请求
    final responseFuture = stream.first; 
    sendMessageToBluetooth(getConfigDataRequest);
    
    try {
      String data = await responseFuture;
      ConfigData configData = ConfigData.fromJson(jsonDecode(data));
      print(configData.toString());
      return configData;
    } catch (e) {
      // 处理超时或错误
      return null;
    }
}

方案2：为每个请求创建独立的单订阅流（更可靠）

如果listenForResponses返回的是全局广播流，容易出现不同请求的响应串扰问题。建议改为每次请求创建独立的单订阅流，确保请求与响应一一对应：

// 在BluetoothController中维护一个StreamController，用于发射所有蓝牙响应
final _responseController = StreamController<String>.broadcast();

// 蓝牙模块收到数据时，调用这个方法发射数据
void onBluetoothDataReceived(String data) {
  _responseController.add(data);
}

// 修改getConfigData，为当前请求创建过滤后的单订阅流
Future<ConfigData?> getConfigData() async {
    // 创建只接收当前请求对应响应的流（如果你的响应有标识，可以用firstWhere过滤）
    final responseStream = _responseController.stream.where((data) {
      // 假设响应里有标识区分是配置数据请求的返回
      ConfigData temp = ConfigData.fromJson(jsonDecode(data));
      return temp.isConfigResponse;
    }).take(1); // 只取第一个匹配的响应

    sendMessageToBluetooth(getConfigDataRequest);
    
    try {
      String data = await responseStream.first;
      ConfigData configData = ConfigData.fromJson(jsonDecode(data));
      print(configData.toString());
      return configData;
    } catch (e) {
      return null;
    }
}

方案3：添加超时处理（避免无限等待）

不管哪种方案，都建议给Future添加超时，防止因为蓝牙模块无响应导致UI一直卡住：

Future<ConfigData?> getConfigData() async {
    var stream = listenForResponses();
    final responseFuture = stream.first;
    sendMessageToBluetooth(getConfigDataRequest);
    
    try {
      String data = await responseFuture.timeout(const Duration(seconds: 5));
      ConfigData configData = ConfigData.fromJson(jsonDecode(data));
      print(configData.toString());
      return configData;
    } on TimeoutException {
      print("蓝牙请求超时");
      return null;
    } catch (e) {
      print("请求出错: $e");
      return null;
    }
}

额外注意点 #

• 确保listenForResponses返回的广播流是正确实现的，避免内部的StreamController出现未正确关闭或重复订阅的问题；
• 如果你的蓝牙响应没有唯一标识，多次连续调用getConfigData可能会出现响应串扰（第二次请求的响应被第一次的Future接收），这时候必须用firstWhere过滤响应；
• 单例的BluetoothController要注意StreamController的生命周期，在不需要时关闭，避免内存泄漏。

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