p-pipe
Async pipeline creator
Creates a reusable pipeline of promise-returning functions to compose and chain together multiple asynchronous operations.
Compose promise-returning & async functions into a reusable pipeline
122 stars
6 watching
16 forks
Language: TypeScript
last commit: almost 4 years ago
Linked from 1 awesome list
wbinnssmith/awesome-promisesRelated projects:
| Repository | Description | Stars |
|---|---|---|
| sindresorhus/p-times | Runs promise-returning & async functions multiple times concurrently | 39 |
| sindresorhus/p-all | Concurrently execute multiple promise-returning functions with optional concurrency limits. | 319 |
| sindresorhus/p-map | A utility for mapping over promises concurrently while controlling concurrency and error handling. | 1,376 |
| sindresorhus/p-memoize | Memoizes promise-returning and async functions to cache consecutive function calls by storing results of identical input. | 397 |
| sindresorhus/p-if | A utility for conditional promise handling and chaining in TypeScript applications. | 60 |
| sindresorhus/p-whilst | An implementation of an async while loop that repeatedly executes a function until a condition is met or fails | 54 |
| sindresorhus/p-map-series | Serializes promise-based operations to ensure predictable order and execution of side effects. | 48 |
| sindresorhus/p-event | Promises an event by waiting for it to be emitted, allowing asynchronous iteration and rejection handling. | 429 |
| sindresorhus/observable-to-promise | Converts an Observable to a Promise for asynchronous data handling | 47 |
| sindresorhus/p-reduce | Transforms an asynchronous list into a single value by applying a reduction function | 68 |
| sindresorhus/p-each-series | Iterates over promises in serial order, stopping at the first failed promise. | 50 |
| sindresorhus/p-tap | Helps tap into a promise chain without affecting its value or state | 132 |
| sindresorhus/p-log | Utility for logging promise values and errors in a chain of operations | 26 |
| sindresorhus/p-filter | Tool for filtering and concurrent execution of promises with an adjustable concurrency level | 75 |
| sindresorhus/into-stream | Converts various input types into readable streams. | 207 |