p-saga

基于 Promise 封装的常用处理异步任务的方法。

方法

series

逐个执行任务

map

异步任务按顺序逐个执行，全部完成后返回全部结果。

reduce

异步任务逐个执行，每个任务能查到已完成的任务，全部完成后返回全部结果。

batch

按固定任务数量并发，逐批次完成全部任务，全部完成后返回全部结果。

outburst

按照指定数量同时启动第一批，每个任务完成后启动一个剩余任务，直至全部完成返回全部结果。

使用

1import { series, map, reduce, batch, outburst } from 'p-saga';
2
3map(
4    Array.from({ length: 20 }).map(
5        () => (page: number) =>
6            fetch(new Request(`/mock/list?page=${page}&size=20`), {
7                method: 'GET',
8            }),
9    ),
10);

全局使用

1// 入口文件
2import 'p-saga/bind';

1// typings.d.ts
2
3declare interface PromiseConstructor {
4    series: <T = any>(tasks: ((index: number, copiedTasks: any[]) => T | Promise<T>)[]): Promise<void>;
5    map: <T = any>(tasks: ((index: number, copiedTasks: any[]) => T | Promise<T>)[]): Promise<T[]>;
6    reduce: <T>(tasks: ((previousValue: T[], index: number, copiedTasks: any[]) => Promise<T[]> | T[])[], initialValue?: T[]): Promise<T[]>;
7    batch: <T = any>(count: number, tasks: ((index: number, batchIndex: number) => T | Promise<T>)[]): Promise<T[]>;
8    outburst: <T = any>(count: number, tasks: Array<(index: number) => T | Promise<T>>): Promise<T[]>;
9}