Dart使用ReactiveX时Too类状态变更无法同步到其他持有类如何解决

问题原因 #

你代码存在3个核心问题导致监听无响应：

• Too类中suject拼写错误（正确应为subject），且未对外暴露BehaviorSubject的stream，无法直接在外部监听
• Foo类中监听stream的代码直接写在类成员定义区域，不符合Dart语法规范，该段代码不会被执行
• 如果你需要所有类同步感知Too的状态变更，必须保证所有类持有同一个Too实例，不能每个类单独实例化新的Too对象

修正后可运行代码 #

Too类实现 #

import 'package:rxdart/rxdart.dart';

class Too {
  bool isLogged = false;
  // 修正拼写错误，改为私有属性避免外部直接修改流
  final BehaviorSubject<bool> _subject = BehaviorSubject<bool>();

  Too({required this.isLogged}) {
    _subject.add(isLogged);
  }

  // 对外暴露只读的stream，供外部监听状态变更
  Stream<bool> get loginStream => _subject.stream;

  void login() {
    isLogged = true;
    _subject.add(isLogged);
  }

  void logOut() {
    isLogged = false;
    _subject.add(isLogged);
  }

  void dispose() {
    _subject.close();
  }

  // 全局单例构造，保证所有类拿到的是同一个Too实例
  static final Too _instance = Too._internal(isLogged: false);
  factory Too.singleton() {
    return _instance;
  }
  Too._internal({required this.isLogged});
}

Foo类实现 #

class Foo {
  // 用单例获取Too实例，和其他业务类共享同一个状态源
  final Too _too = Too.singleton();

  Foo() {
    // 监听逻辑放在构造函数中，类实例化时自动启动监听
    _too.loginStream.listen((event) {
      print('Foo收到登录状态变更: $event');
    });
  }
}

效果验证 #

你可以通过以下入口代码测试功能：

void main() {
  // 实例化Foo启动监听
  Foo foo = Foo();
  // 任意业务位置获取同一个Too单例修改状态
  Too globalToo = Too.singleton();
  globalToo.login(); // Foo会打印：Foo收到登录状态变更: true
  globalToo.logOut(); // Foo会打印：Foo收到登录状态变更: false
}

实现逻辑说明 #

Dart中RxDart的BehaviorSubject机制和RxJS完全一致，会自动缓存最新的状态值，新加入的监听者会立刻收到当前最新状态。通过全局单例保证所有持有Too实例的类监听的是同一个状态流，任意位置调用login/logOut修改状态，所有监听者都会同步收到变更通知，符合你的需求。

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