Dart 中断Future

liutong 2020-02-22

中断future

方法1)

import 'package:async/async.dart';

void main() {
  var get = CancelableOperation.fromFuture(
    Future.delayed(Duration(seconds: 3)),
    onCancel: () => print('onCancel'),
  );

  get.value.then(print);
  Future.delayed(Duration(seconds: 1)).then((_) => get.cancel());
}

方法2)

import 'package:async/async.dart';

void main() {
  var completer = CancelableCompleter(onCancel: () => print('onCancel'));
  completer.complete(Future.delayed(Duration(seconds: 3))); // 添加future
  completer.operation.value.then(print);// 订阅future
  Future.delayed(Duration(seconds: 1)).then((_) => completer.operation.cancel());//中断future
}

相关推荐