Flutter未知功能插件f4的介绍与使用

简介

f4 是一个增强版的 Future 辅助函数库，兼容 Node.js 的 Promise 库（如 Bluebird）。它支持并发和取消操作。该库通过一个名为 F4 的类提供静态方法，以避免意外污染全局命名空间。虽然在 Dart 中这可能有点反常，但其中一些辅助函数应该由 Dart 本身原生支持。

目前，f4 支持以下辅助方法：all、map、chain、props、one、forEach、create 和 reflect。

AbortController 类用于取消 Future 操作，并且与 Fetch API 对应的类兼容。

注意：此库尚未在生产环境中测试过，是在周末编写以帮助我学习 Dart 而创建的。欢迎提交 Pull Request。

使用示例

简单示例

import 'package:f4/f4.dart';

main() async {
  final r = await F4.map([1, 2, 3, 4], (int i) => Future.value(i), concurrency: 2);
  print(r); // [1, 2, 3, 4]
}

完整示例

import 'dart:math';
import 'dart:async';
import 'package:f4/f4.dart';

// 延迟指定毫秒数后返回结果
Future sleep(int pnum, {int? res, int ms = 500}) {
  print('run #$pnum');

  return Future.delayed(Duration(milliseconds: Random().nextInt(ms) + ms))
      .then((_) => pnum + (res ?? 0));
}

// 创建一个定时器，在指定秒数后执行回调
Timer timeout(int s, Function fn) =>
    Timer(Duration(seconds: s), () => Function.apply(fn, null));

void main() async {
  final chain = [
    () => sleep(1),
    (int res) => sleep(2, res: res),
    (int res) => sleep(3, res: res),
    (int res) => sleep(4, res: res)
  ];

  final list = [
    () => sleep(1),
    () => sleep(2),
    () => sleep(3),
    () => sleep(4),
  ];

  final props = {
    'a': () => sleep(1),
    'b': () => sleep(2),
    'c': () => sleep(3),
    'd': () => sleep(4)
  };

  print('---forEach---');
  print(await F4.forEach(list));

  print('\n---chain---');
  print(await F4.chain(chain));

  print('\n---all---');
  print(await F4.all(list, concurrency: 2));

  print('\n---one---');
  print(await F4.one(list[0]));

  print('\n---props---');
  print(await F4.props(props, concurrency: 2));

  print('\n---map---');
  print(await F4.map([1, 2, 3, 4], sleep, concurrency: 2));

  print('\n---abort:onAbort---');
  final ctl1 = AbortController(onAbort: (e) => print('onAbort: $e'));
  timeout(1, () => ctl1.abort('cancel'));
  final v = await F4.chain(chain, abortSignal: ctl1.signal);
  print('************* $v');

  print('\n---abort:catch---');
  final ctl2 = AbortController();
  timeout(1, () => ctl2.abort('cancel'));
  try {
    await F4.forEach(list, abortSignal: ctl2.signal);
  } catch (e) { print('catch: $e'); };

  print('\n---create---');
  print(await F4.create((resolve, reject) => timeout(1, () => resolve(1))));

  try {
    await F4.create((resolve, reject) =>
        timeout(1, () => reject(RejectionError(message: 'foo'))));
  } catch (e) { print(e.runtimeType); }

  print('\n---reflect---');
  print(await F4.reflect(Future.value(1)));
  print(await F4.reflect(Future.error('err')));
}