如果错误实际上是由您发布的代码引起的,那么我将添加一个检查以确保在
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();
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)