使用 Bloc、RxDart 和 StreamBuilder、无状态 vs 有状态和处置的 Flutter 干净架构

Question

我正在尝试实现一个干净的架构，不依赖于业务逻辑层中的框架。

以下示例是仅包含文本的屏幕。我在存储库中进行 API Rest 调用，并将响应添加到通过将更新 Text 的 StreamBuilder 侦听的 BehaviorSubject。由于是 StatefulWidget，我使用 dispose 方法来关闭 BehaviorSubject 的 StreamController。

该示例是简化的，没有错误/加载状态处理，没有依赖项注入，基类，处置接口等。

class Bloc {
  final UserReposiotry _userReposiotry;
  final BehaviorSubject<int> _activeUsersCount = BehaviorSubject.seeded(0);

  Bloc(this._userReposiotry) {
    _getActiveUsersCount();
  }

  void _getActiveUsersCount() async {
    final response = await _userReposiotry.getActiveUsersCount();
    _activeUsersCount.add(response.data);
  }

  ValueStream<int> get activeUsersCount => _activeUsersCount.stream;

  void dispose() async {
    await _activeUsersCount.drain(0);
    _activeUsersCount.close();
  }
}

class StatefulScreen extends StatefulWidget {
  final Bloc bloc;

  const StatefulScreen({Key? key, required this.bloc}) : super(key: key);

  @override
  State<StatefulScreen> createState() => _StatefulScreenState();
}

class _StatefulScreenState extends State<StatefulScreen> {
  @override
  Widget build(BuildContext context) {
    final stream = widget.bloc.activeUsersCount;
    return StreamBuilder<int>(
      stream: stream,
      initialData: stream.value,
      builder: (context, snapshot) {
        return Text(snapshot.data.toString());
      }
    );
  }

  @override
  void dispose() {
    widget.bloc.dispose();
    super.dispose();
  }
}

我对这种方法有以下疑问。

1. StreamBuilder 自动取消 stream 订阅，但不会关闭 StreamController。我知道如果你正在读取文件就应该关闭它，但是在这种情况下，如果我不手动关闭它，一旦 StatefulScreen 不再位于导航堆栈中，它是否会被销毁，还是内存泄漏？
2. 我见过很多人使用 StatelessWidget 而不是 StatefulWidget 使用 Stream 和 StreamBuilder 方法，如果是的话确实需要关闭 BehaviorSubject 这是一个问题，因为我们没有 dispose 方法，我找到了 WillPopScope 但它不会' t 在所有导航情况下都会触发并且并且更重要的是，像 WillPopScope 这样的方法会更高效，还是在一个内部有一个 StatefulWidget wrapper (BlocProvider) StatelessWidget 只是为了进行处理，而不是直接使用 StatefulWidget ，如果是这样，您能指出该实现的示例吗？
3. 我目前正在为具有动画或控制器（地图、文本输入、网页浏览...）或需要关闭的流的小部件选择 StatefulWidget ，其余的 StatelessWidget，这是正确的还是我错过了什么？
4. 关于 drain 方法，我使用它是因为在 API 休息调用正在进行时返回时遇到错误，我找到了 RxDart 团队的成员说实际上没有必要调用 drain 所以我也对此感到困惑......，错误：

从 addStream 添加项目时无法关闭主题

感谢您的宝贵时间。