npmpackage.info

Gathering detailed insights and metrics for p-saga

Other packages similar to p-saga

@redux-saga/delay-p

1.2.1

Promisified setTimeout

@byungi/p-cancel-saga

0.2.1

A cancelable promise with saga.

@mahyar-kd/nestjs-saga

1.0.0

p-saga

1.1.0

809.00 B

923

Installations

npm install p-saga

Developer Guide

BETA

Typescript

No

Module System

CommonJS

Node Version

16.20.2

NPM Version

8.19.4 Score

Supply Chain

Quality

76.5

Maintenance

100

Vulnerability

100

License

Releases

Unable to fetch releases

Contributors

Love this project? Help keep it running — sponsor us today! 🚀

Download Statistics

Total Downloads

923

Last Day

Last Week

Last Month

Last Year

203

Bundle Size

2.27 kB

Minified

809.00 B

Minified + Gzipped

Bundlephobia

Maintainers

Package Meta Information

Latest Version

1.1.0

Package Id

p-saga@1.1.0

Unpacked Size

55.33 kB

Size

7.44 kB

File Count

NPM Version

8.19.4

Node Version

16.20.2

Publised On

14 May 2024

Total Downloads

Cumulative downloads

Total Downloads

923

Last day

Compared to previous day

Last week

250%

Compared to previous week

Last month

200%

Compared to previous month

Last year

-71.8%

203

Compared to previous year

Daily Downloads

Weekly Downloads

Monthly Downloads

Yearly Downloads

No dependencies detected.

Versions

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}

No vulnerabilities found.

No security vulnerabilities found.