Flutter资源管理工具插件disposable_utils的使用

Flutter资源管理工具插件disposable_utils的使用

在Dart和Flutter中，没有一个统一的方法来释放对象资源。例如，StreamController.close()、StreamSubscription.cancel() 和不同的 Flutter 对象中的 dispose() 方法都做着同样的事情——释放持有的信息。但它们并没有一个统一的接口。这就是 Disposable 的作用。

DisposableCollector 是一个可以组合多个可释放对象的集合，可以一次性释放它们。它还提供了扩展方法来简化流的操作。

你是否注意到以下问题？

在 Dart 和 Flutter 中，没有一个统一的方法来释放对象资源。例如：

class SomeDisposable {
  /// ...

  final _subscription = someStream.listen(
    (value) => doSomethingWith(value)
  );

  /// ...

  void dispose() {
    _subscription.cancel();
  }
}

使用 DisposableCollector 后，代码会变成这样：

class SomeDisposable extends DisposableCollector {
  /// ...
  someStream
    .listen((value) => doSomethingWith(value))
    .addTo(this);
  
  /// ...
}

你还可以通过工厂方法将任何对象转换为 Disposable：

final disposable = Disposable.create(yourObject, () => yourObject.close());
// 或者
final disposable = yourObject.toDisposable(() => yourObject.close());

完整示例代码

以下是一个完整的示例代码，展示了如何使用 DisposableCollector 来管理资源：

import 'dart:async';
import 'package:disposable_utils/disposable_utils.dart';

void main() {
  final service = new DataService();
  final bloc = new Bloc(service);

  bloc.stream.listen(
    (v) => print(v),
    onDone: () => print("Complete")
  );

  bloc.dispose();

  // 你会看到打印出 "Complete"，因为 bloc 在接收到数据服务的值之前已经被释放。
}

/// 模仿 BLoC 作为流的存储
class Bloc extends DisposableCollector {
  Stream<int> get stream => _streamController.stream;
  final StreamController<int> _streamController = new StreamController();

  Bloc(DataService service) {
    _streamController.addTo(this);

    /// 当然，你可以写成如下形式：
    /// ```
    /// final v = await service.getValue();
    /// _streamController.add(v);
    /// ````
    /// 或者
    /// ```
    /// _streamController.addStream(service.getValue().asStream());
    /// ```
    /// 但在这些情况下，如果你在获取未来/流的值之前释放了你的 StreamController，
    /// 你会看到不同的异常。但是当你使用 `addTo(Disposable)` 扩展方法时，
    /// 会在 StreamController 被释放时取消订阅流，不会抛出异常。

    service.getValue().asStream()
      .listen((v) => _streamController.add(v))
      .addTo(this);
  }
}

/// 模仿数据服务
class DataService {
  Future<int> getValue() async {
    await Future.delayed(Duration(seconds: 1));
    return 3;
  }
}