如何实现MainFormBloc监听多子Bloc状态并触发FormIsReadyState？

方法一：手动监听子Bloc状态并维护本地标记 #

在MainFormBloc中分别监听两个子Bloc的状态变化，用布尔变量记录各自的有效性，每次状态更新后检查两者是否同时有效，再决定是否更新主Bloc的状态。

class MainFormBloc extends Bloc<MainFormEvent, MainFormState> {
  final UsernameBloc usernameBloc;
  final PasswordBloc passwordBloc;
  late final StreamSubscription _usernameSubscription;
  late final StreamSubscription _passwordSubscription;

  bool _isUsernameValid = false;
  bool _isPasswordValid = false;

  MainFormBloc({
    required this.usernameBloc,
    required this.passwordBloc,
  }) : super(FormInitialState()) {
    // 监听用户名Bloc状态流
    _usernameSubscription = usernameBloc.stream.listen((state) {
      _isUsernameValid = state is UsernameValid;
      _checkFormStatus();
    });

    // 监听密码Bloc状态流
    _passwordSubscription = passwordBloc.stream.listen((state) {
      _isPasswordValid = state is PasswordValid;
      _checkFormStatus();
    });

    // 初始化时检查子Bloc当前状态
    _isUsernameValid = usernameBloc.state is UsernameValid;
    _isPasswordValid = passwordBloc.state is PasswordValid;
    _checkFormStatus();
  }

  /// 检查表单就绪状态并更新
  void _checkFormStatus() {
    final shouldBeReady = _isUsernameValid && _isPasswordValid;
    if (shouldBeReady && state is! FormIsReadyState) {
      emit(FormIsReadyState());
    } else if (!shouldBeReady && state is FormIsReadyState) {
      emit(FormInitialState()); // 替换为你的非就绪状态类
    }
  }

  @override
  Future<void> close() {
    // 取消订阅防止内存泄漏
    _usernameSubscription.cancel();
    _passwordSubscription.cancel();
    return super.close();
  }
}

方法二：使用CombineLatest合并状态流（依赖rxdart） #

借助RxDart的CombineLatestStream合并两个子Bloc的状态流，直接判断两者是否同时有效，再响应状态变化。

首先在pubspec.yaml中添加依赖：

dependencies:
  rxdart: ^0.27.7 # 使用最新稳定版

代码示例：

import 'package:rxdart/rxdart.dart';

class MainFormBloc extends Bloc<MainFormEvent, MainFormState> {
  final UsernameBloc usernameBloc;
  final PasswordBloc passwordBloc;
  late final StreamSubscription _combinedSubscription;

  MainFormBloc({
    required this.usernameBloc,
    required this.passwordBloc,
  }) : super(FormInitialState()) {
    // 合并两个子Bloc的状态流
    _combinedSubscription = CombineLatestStream.combine2(
      usernameBloc.stream,
      passwordBloc.stream,
      (UsernameState usernameState, PasswordState passwordState) => 
        usernameState is UsernameValid && passwordState is PasswordValid,
    ).listen((isFormReady) {
      if (isFormReady && state is! FormIsReadyState) {
        emit(FormIsReadyState());
      } else if (!isFormReady && state is FormIsReadyState) {
        emit(FormInitialState());
      }
    });

    // 初始化时检查初始状态
    final initialIsReady = usernameBloc.state is UsernameValid && 
                           passwordBloc.state is PasswordValid;
    if (initialIsReady) {
      emit(FormIsReadyState());
    }
  }

  @override
  Future<void> close() {
    _combinedSubscription.cancel();
    return super.close();
  }
}

关键注意事项 #

• 取消订阅：必须在Bloc关闭时取消所有StreamSubscription，避免内存泄漏。
• 初始状态检查：子Bloc可能在MainFormBloc初始化前就已处于有效状态，因此必须在构造函数中额外检查一次。
• 避免重复emit：emit前判断当前状态是否已为目标状态，防止不必要的状态更新。

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