31

我正在尝试使用 bloc 模式来管理来自 API 的数据并将它们显示在我的小部件中。我能够从 API 获取数据并对其进行处理和显示，但我使用的是底部导航栏，当我更改选项卡并转到上一个选项卡时，它返回此错误：

未处理的异常：错误状态：调用关闭后无法添加新事件。

我知道这是因为我正在关闭流然后尝试添加到它，但我不知道如何修复它，因为不处理publishsubject将导致memory leak. 这是我的用户界面代码：

class CategoryPage extends StatefulWidget {
  @override
  _CategoryPageState createState() => _CategoryPageState();
}

class _CategoryPageState extends State<CategoryPage> {
  @override
  void initState() {
    serviceBloc.getAllServices();
    super.initState();
  }

  @override
  void dispose() {
    serviceBloc.dispose();
    super.dispose();
  }

  @override
  Widget build(BuildContext context) {
    return StreamBuilder(
      stream: serviceBloc.allServices,
      builder: (context, AsyncSnapshot<ServiceModel> snapshot) {
        if (snapshot.hasData) {
          return _homeBody(context, snapshot);
        }
        if (snapshot.hasError) {
          return Center(
            child: Text('Failed to load data'),
          );
        }
        return CircularProgressIndicator();
      },
    );
  }
}

_homeBody(BuildContext context, AsyncSnapshot<ServiceModel> snapshot) {
  return Stack(
      Padding(
          padding: EdgeInsets.only(top: screenAwareSize(400, context)),
          child: _buildCategories(context, snapshot))
    ],
  );
}

_buildCategories(BuildContext context, AsyncSnapshot<ServiceModel> snapshot) {
  return Padding(
    padding: EdgeInsets.symmetric(vertical: 20),
    child: GridView.builder(
      gridDelegate: SliverGridDelegateWithFixedCrossAxisCount(
          crossAxisCount: 3, crossAxisSpacing: 3.0),
      itemCount: snapshot.data.result.length,
      itemBuilder: (BuildContext context, int index) {
        return InkWell(
          child: CategoryWidget(
            title: snapshot.data.result[index].name,
            icon: Icons.phone_iphone,
          ),
          onTap: () {},
        );
      },
    ),
  );
}

这是我的集团代码：

class ServiceBloc extends MainBloc {
  final _repo = new Repo();
  final PublishSubject<ServiceModel> _serviceController =
      new PublishSubject<ServiceModel>();
  Observable<ServiceModel> get allServices => _serviceController.stream;
  getAllServices() async {
    appIsLoading();
    ServiceModel movieItem = await _repo.getAllServices();
    _serviceController.sink.add(movieItem);
    appIsNotLoading();
  }

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

ServiceBloc serviceBloc = new ServiceBloc();

我没有包含 repo 和 API 代码，因为它不在此错误的主题中。

4

7 回答 7

30

用于StreamController.isClosed检查控制器是否关闭，如果未关闭则向其添加数据。

if (!_controller.isClosed) 
  _controller.sink.add(...); // safe to add data as _controller isn't closed yet

从文档：

流控制器是否关闭以添加更多事件。

控制器通过调用 close 方法关闭。无法通过调用 add 或 addError 将新事件添加到关闭的控制器。

如果控制器关闭，“done”事件可能还没有交付，但已经安排好了，再添加更多事件已经来不及了。

于 2019-10-02T04:24:31.377 回答
19

如果错误实际上是由您发布的代码引起的，我只需添加一个检查以确保在dispose()调用后没有添加新事件。

class ServiceBloc extends MainBloc {
  final _repo = new Repo();
  final PublishSubject<ServiceModel> _serviceController =
      new PublishSubject<ServiceModel>();
  Observable<ServiceModel> get allServices => _serviceController.stream;
  getAllServices() async {
    // do nothing if already disposed
    if(_isDisposed) {
      return;
    }
    appIsLoading();
    ServiceModel movieItem = await _repo.getAllServices();
    _serviceController.sink.add(movieItem);
    appIsNotLoading();
  }

  bool _isDisposed = false;
  void dispose() {
    _serviceController.close();
    _isDisposed = true;
  }
}

ServiceBloc serviceBloc = new ServiceBloc();
于 2019-04-05T15:06:12.277 回答
3

我遇到了同样的错误，并注意到如果您检查 isClosed，则屏幕不会更新。在您的代码中，您必须从 Bloc 文件中删除最后一行：

ServiceBloc serviceBloc = new ServiceBloc();

并将这一行放在CategoryPage 中initState() 之前。这样，您的小部件正在创建和处置该集团。以前，小部件只处理 bloc，但在重新创建小部件时永远不会重新创建它。

于 2020-01-06T18:27:58.303 回答
3

除了提供的解决方案之外，我认为您还应该通过以下方式排出allServicesServiceBloc 中使用的流：

@override
void dispose() {
      ...
      allServices?.drain(); 
}
于 2020-05-11T19:09:01.833 回答
2

@cwhisperer 是绝对正确的。如下所示，在小部件中初始化和处理您的块。

final ServiceBloc serviceBloc = new ServiceBloc();

  @override
  void initState() {
    serviceBloc.getAllServices();
    super.initState();
  }

  @override
  void dispose() {
    serviceBloc.dispose();
    super.dispose();
  }

并ServiceBloc serviceBloc = new ServiceBloc();从您的class ServiceBloc

于 2020-02-05T02:43:57.060 回答
1 
ServiceBloc serviceBloc = new ServiceBloc();

// 删除此代码 // 不要在同一页面中初始化会导致错误状态的类。

于 2020-08-09T07:08:06.420 回答
1

我在生产中也遇到了这个问题，我意识到我们应该在释放 Widget 时释放 BehaviorSubject（或任何其他 StreamController），或者在添加新值之前检查 Stream 是否关闭。

这是一个很好的扩展来完成所有工作：

extension BehaviorSubjectExtensions <T> on BehaviorSubject<T> {
  set safeValue(T newValue) => isClosed == false ? add(newValue) : () {};
}

你可以像这样使用它：

class MyBloc {
  final _data = BehaviorSubject<String>();
  
  void fetchData() {
    // get your data from wherever it is located
    _data.safeValue = 'Safe to add data';
  }

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

如何在 Widget 中配置：

class CategoryPage extends StatefulWidget {
  @override
  _CategoryPageState createState() => _CategoryPageState();
}

class _CategoryPageState extends State<CategoryPage> {
  late MyBloc bloc;

  @override
  void initState() {
    bloc = MyBloc();
    bloc.fetchData();
    super.initState();
  }

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

  // Other part of your Widget
}
于 2022-01-31T09:45:53.917 回答