当我的 Get Controller 从内存中删除时，如何关闭流？

Question

我正在使用以下软件包 https://pub.dev/packages/get 。

我有以下控制器

class GroupController extends GetController{
  StreamController<GroupModel> _streamController = BehaviorSubject();
  Stream<GroupModel> get stream => _streamController.stream;

  GroupController(DatabaseService database, GroupModel group)
  {
   _streamController.addStream(database.groupStream(group));
  }

  @override
  void dispose(){
    print('dispose');
    _streamController.close();
    super.dispose();
  }
}

但是当我调用它时，永远不会调用 dispose。我这样称呼它

GetBuilder<GroupController>(
        init: GroupController(database, _group),
        builder: (GroupController groupController) => StreamBuilder(
          stream: groupController.stream,
          builder: (BuildContext context, AsyncSnapshot<GroupModel> groupSnapshot) {

我希望每当控制器从内存中删除时调用我的控制器的 dispose 方法。

我注意到 GetBuilder 有一个 dispose 回调。它需要来自小部件的状态。那么我是否需要使包含控制器的小部件成为有状态的？或者我是否需要传递一个新的状态小部件来保存状态？文档并不是全部都清楚。如何在我的控制器上调用 dispose？

我注意到每当控制器从内存中删除时都会有一个控制台日志，难道没有回调以便我可以在那里关闭流吗？我真的很想避免使小部件有状态。

编辑

class GroupController extends GetController{
  StreamController<GroupModel> _streamController = BehaviorSubject();
  Stream<GroupModel> get stream => _streamController.stream;

  GroupController(DatabaseService database, GroupModel group)
  {
   _streamController.addStream(database.groupStream(group));
  }

  @override
  void close(){
    print('log if close is invoked');
    _streamController.close();
    super.close();
  }
}

生成以下日志

I/flutter (23404): log if close is invoked 
I/flutter (23404): Close can't be called 
I/flutter (23404): [GET] GroupController deleted from memory

尝试关闭控制器时出现错误

Answer 1

如果您在 GetController 中插入“dispose”，它将被忽略。这是因为 disposing 是 StatefulWidget 类中用于丢弃小部件的方法，而不是用于丢弃控制器，尤其是因为 Get 会在不再需要时自动智能地丢弃控制器以释放资源。如果要关闭流，Get 会自动执行，只要将流插入 onClose 方法即可。

class GroupController extends GetxController {
  StreamController<GroupModel> _streamController = BehaviorSubject();
  Stream<GroupModel> get stream => _streamController.stream;

  GroupController(DatabaseService database, GroupModel group);
  
  @override
  void onInit() {
    _streamController.addStream(database.groupStream(group));
    super.onInit();
  }

  // this
  @override
  void onClose() {
    print('dispose');
    _streamController.close();
    super.onClose();
  }
}

如果您使用的是旧版本的 Get，您可以手动使用相同的关闭和关闭方法：

GetBuilder<GroupController>(
        init: GroupController(database, _group),
        builder: (GroupController groupController) => StreamBuilder(
          stream: groupController.stream,
          builder: (BuildContext context, AsyncSnapshot<GroupModel> groupSnapshot) {

Answer 2

这可能就是您想要的方式。不要在构造函数中添加流，因为这会在控制器重建时导致问题。因为它将再次将流添加到构造函数。

import 'dart:async';
import 'package:get/get.dart';
import 'package:rxdart/rxdart.dart';

class GetStreamController<T> extends GetController {
  final Stream<T> Function() value;
  StreamController<T> _streamController = BehaviorSubject();
  StreamSubscription _streamSubscription;
  Stream<T> get stream => _streamController.stream;

  GetStreamController(this.value);
  @override
  void onInit()
  {
    super.onInit();
    _streamSubscription = value().listen((event) {
      _streamController.add(event);
    });
  }

  @override
  void onClose()
  {
    super.onClose();
    _streamSubscription.cancel();
    _streamController.close();
  }
}