Cubit包装流仅第二次打开页面时生效的问题排查

核心问题定位 #

首次加载空白、第二次正常的现象，本质是**FitnessMachineDiscoveryService.start()异步方法未被正确等待执行**，导致Cubit创建时设备流还未开始发射事件。Bloc/Cubit构造函数为同步逻辑，无法直接在内部处理异步初始化，这是关键限制。

具体修复方案 #

1. 给Cubit新增异步初始化方法 #

修改FitnessMachineDiscoveryCubit，将异步启动逻辑抽离为单独方法，确保等待服务启动后再监听设备流：

class FitnessMachineDiscoveryCubit extends Cubit<FitnessMachineDiscoveryState> {
  final FitnessMachineDiscoveryService _discoveryService;

  FitnessMachineDiscoveryCubit(this._discoveryService) : super(FitnessMachineDiscoveryInitial());

  Future<void> initialize() async {
    try {
      // 等待服务启动完成
      await _discoveryService.start();
      // 启动后监听设备流
      _listenToDeviceStream();
    } catch (e) {
      emit(FitnessMachineDiscoveryError(e.toString()));
    }
  }

  void _listenToDeviceStream() {
    _discoveryService.deviceStream.listen((devices) {
      emit(FitnessMachineDiscoveryLoaded(devices));
    });
  }

  @override
  Future<void> close() {
    // 页面销毁时停止服务，避免资源泄漏
    _discoveryService.stop();
    return super.close();
  }
}

2. 在页面初始化时触发Cubit的初始化方法 #

在DeviceSelectionScreen的initState中获取Cubit并调用异步初始化：

class DeviceSelectionScreen extends StatefulWidget {
  const DeviceSelectionScreen({super.key});

  @override
  State<DeviceSelectionScreen> createState() => _DeviceSelectionScreenState();
}

class _DeviceSelectionScreenState extends State<DeviceSelectionScreen> {
  late FitnessMachineDiscoveryCubit _cubit;

  @override
  void initState() {
    super.initState();
    _cubit = context.read<FitnessMachineDiscoveryCubit>();
    // 页面初始化时启动蓝牙扫描
    _cubit.initialize();
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(title: const Text('选择蓝牙设备')),
      body: FitnessMachineList(),
    );
  }
}

3. 优化GetIt依赖注入逻辑 #

根据服务的生命周期调整注册方式：

• 如果服务需要每次打开页面都重新初始化，用registerFactory：

GetIt.I.registerFactory<FitnessMachineDiscoveryService>(
  () => FitnessMachineDiscoveryService(),
);

• 如果用单例模式，需给服务添加重置方法，避免上次扫描的流残留：

// 服务类新增重置方法
class FitnessMachineDiscoveryService {
  void reset() {
    // 重置流控制器、清空设备列表等操作
  }
}

// Cubit初始化时先重置服务
Future<void> initialize() async {
  _discoveryService.reset();
  await _discoveryService.start();
  _listenToDeviceStream();
}

4. 完善BlocBuilder的状态处理 #

确保FitnessMachineList能正确响应初始状态，避免空白：

class FitnessMachineList extends StatelessWidget {
  @override
  Widget build(BuildContext context) {
    return BlocBuilder<FitnessMachineDiscoveryCubit, FitnessMachineDiscoveryState>(
      builder: (context, state) {
        if (state is FitnessMachineDiscoveryInitial) {
          return const Center(child: CircularProgressIndicator());
        } else if (state is FitnessMachineDiscoveryLoaded) {
          return ListView.builder(
            itemCount: state.devices.length,
            itemBuilder: (context, index) {
              return ListTile(title: Text(state.devices[index].name));
            },
          );
        } else if (state is FitnessMachineDiscoveryError) {
          return Center(child: Text('加载失败：${state.message}'));
        }
        return const SizedBox();
      },
    );
  }
}

无效尝试的原因说明 #

• BlocProvider.create是同步方法，无法直接嵌入异步逻辑，异步初始化放在这里会导致代码执行顺序混乱。
• BlocBuilder是UI构建组件，在此处执行异步操作会引发重复构建、状态异常等问题，不符合状态管理规范。

通过将异步初始化逻辑抽离到Cubit的独立方法，并在页面initState中调用，既保证了异步操作的正确等待，又符合Bloc/Cubit的设计原则。

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