build: dependencies update

arpinum-oss · Mar 6, 2024 · a014142 · a014142
1 parent 5ebd575
commit a014142
Show file tree

Hide file tree

Showing 41 changed files with 5,925 additions and 4,348 deletions.
diff --git a/benchmarks/map.js b/benchmarks/map.js
@@ -12,15 +12,15 @@ run();
 async function run() {
   await benchmark(
     () => map((f) => f(), createPromiseFuncs()),
-    "Map (concurrency: 3)"
+    "Map (concurrency: 3)",
   );
   await benchmark(
     () => mapWithOptions((f) => f(), { concurrency: 1 }, createPromiseFuncs()),
-    "Map (concurrency: 1)"
+    "Map (concurrency: 1)",
   );
   await benchmark(
     () => mapSeries((f) => f(), createPromiseFuncs()),
-    "Map series"
+    "Map series",
   );
 }
 

diff --git a/docs/api.md b/docs/api.md
@@ -173,7 +173,7 @@ const { timeout } = require("@arpinum/promising");
 
 timeout(
   300,
-  resolveAfter
+  resolveAfter,
 )(5000)
   .then(() => console.log("Will not be called"))
   .catch(console.error);
@@ -198,7 +198,7 @@ const { timeoutWithOptions } = require("@arpinum/promising");
 timeoutWithOptions(
   300,
   { createError },
-  resolveAfter
+  resolveAfter,
 )(5000)
   .then(() => console.log("Will not be called"))
   .catch(console.error);
@@ -274,7 +274,7 @@ queue.enqueue(() => eventuallyLog("3"));
 
 function eventuallyLog(message) {
   return new Promise((resolve) => setTimeout(resolve, 1000)).then(() =>
-    console.log(message)
+    console.log(message),
   );
 }
 ```
@@ -310,7 +310,7 @@ stack.push(() => eventuallyLog("3"));
 
 function eventuallyLog(message) {
   return new Promise((resolve) => setTimeout(resolve, 1000)).then(() =>
-    console.log(message)
+    console.log(message),
   );
 }
 ```

diff --git a/examples/queue.js b/examples/queue.js
@@ -10,6 +10,6 @@ queue.enqueue(() => eventuallyLog("3"));
 
 function eventuallyLog(message) {
   return new Promise((resolve) => setTimeout(resolve, 1000)).then(() =>
-    console.log(message)
+    console.log(message),
   );
 }
diff --git a/examples/queue.ts b/examples/queue.ts
@@ -8,6 +8,6 @@ queue.enqueue(() => eventuallyLog("3"));
 
 function eventuallyLog(message: string) {
   return new Promise((resolve) => setTimeout(resolve, 1000)).then(() =>
-    console.log(message)
+    console.log(message),
   );
 }
diff --git a/examples/queueCapacity.js b/examples/queueCapacity.js
@@ -16,6 +16,6 @@ setTimeout(() => clearInterval(interval), 5000);
 
 function eventuallyPrint(iteration) {
   return new Promise((resolve) => setTimeout(resolve, 700)).then(() =>
-    console.log(`Processing #${iteration}`)
+    console.log(`Processing #${iteration}`),
   );
 }
diff --git a/examples/queueCapacity.ts b/examples/queueCapacity.ts
@@ -14,6 +14,6 @@ setTimeout(() => clearInterval(interval), 5000);
 
 function eventuallyPrint(iteration: number) {
   return new Promise((resolve) => setTimeout(resolve, 700)).then(() =>
-    console.log(`Processing #${iteration}`)
+    console.log(`Processing #${iteration}`),
   );
 }
diff --git a/examples/queueConcurrency.js b/examples/queueConcurrency.js
@@ -24,6 +24,6 @@ setTimeout(() => {
 
 function eventuallyLog(message, delay) {
   return new Promise((resolve) => setTimeout(resolve, delay)).then(() =>
-    console.log(message)
+    console.log(message),
   );
 }
diff --git a/examples/queueConcurrency.ts b/examples/queueConcurrency.ts
@@ -22,6 +22,6 @@ setTimeout(() => {
 
 function eventuallyLog(message: string, delay: number) {
   return new Promise((resolve) => setTimeout(resolve, delay)).then(() =>
-    console.log(message)
+    console.log(message),
   );
 }
diff --git a/examples/retryEndlessly.js b/examples/retryEndlessly.js
@@ -8,7 +8,7 @@ const readFileAsync = promisify(readFile);
 
 const readFileAsyncWithRetry = retryWithOptions(
   { endlessly: true, onTryError },
-  readFileAsync
+  readFileAsync,
 );
 
 function onTryError(error) {

diff --git a/examples/retryEndlessly.ts b/examples/retryEndlessly.ts
@@ -6,7 +6,7 @@ const readFileAsync = promisify(readFile);
 
 const readFileAsyncWithRetry = retryWithOptions(
   { endlessly: true, onTryError },
-  readFileAsync
+  readFileAsync,
 );
 
 function onTryError(error: Error) {

diff --git a/examples/retryWithOptions.js b/examples/retryWithOptions.js
@@ -8,7 +8,7 @@ const readFileAsync = promisify(readFile);
 
 const readFileAsyncWithRetry = retryWithOptions(
   { count: 5, onTryError, onFinalError },
-  readFileAsync
+  readFileAsync,
 );
 
 function onTryError(error) {

diff --git a/examples/retryWithOptions.ts b/examples/retryWithOptions.ts
@@ -6,7 +6,7 @@ const readFileAsync = promisify(readFile);
 
 const readFileAsyncWithRetry = retryWithOptions(
   { count: 5, onTryError, onFinalError },
-  readFileAsync
+  readFileAsync,
 );
 
 function onTryError(error: Error) {

diff --git a/examples/stack.js b/examples/stack.js
@@ -12,6 +12,6 @@ stack.push(() => eventuallyLog("5"));
 
 function eventuallyLog(message) {
   return new Promise((resolve) => setTimeout(resolve, 1000)).then(() =>
-    console.log(message)
+    console.log(message),
   );
 }
diff --git a/examples/stack.ts b/examples/stack.ts
@@ -10,6 +10,6 @@ stack.push(() => eventuallyLog("5"));
 
 function eventuallyLog(message: string) {
   return new Promise((resolve) => setTimeout(resolve, 1000)).then(() =>
-    console.log(message)
+    console.log(message),
   );
 }
diff --git a/examples/stackCapacity.js b/examples/stackCapacity.js
@@ -16,6 +16,6 @@ setTimeout(() => clearInterval(interval), 5000);
 
 function eventuallyPrint(iteration) {
   return new Promise((resolve) => setTimeout(resolve, 700)).then(() =>
-    console.log(`Processing #${iteration}`)
+    console.log(`Processing #${iteration}`),
   );
 }
diff --git a/examples/stackCapacity.ts b/examples/stackCapacity.ts
@@ -14,6 +14,6 @@ setTimeout(() => clearInterval(interval), 5000);
 
 function eventuallyPrint(iteration: number) {
   return new Promise((resolve) => setTimeout(resolve, 700)).then(() =>
-    console.log(`Processing #${iteration}`)
+    console.log(`Processing #${iteration}`),
   );
 }
diff --git a/examples/stackConcurrency.js b/examples/stackConcurrency.js
@@ -24,6 +24,6 @@ setTimeout(() => {
 
 function eventuallyLog(message, delay) {
   return new Promise((resolve) => setTimeout(resolve, delay)).then(() =>
-    console.log(message)
+    console.log(message),
   );
 }
diff --git a/examples/stackConcurrency.ts b/examples/stackConcurrency.ts
@@ -22,6 +22,6 @@ setTimeout(() => {
 
 function eventuallyLog(message: string, delay: number) {
   return new Promise((resolve) => setTimeout(resolve, delay)).then(() =>
-    console.log(message)
+    console.log(message),
   );
 }
diff --git a/examples/timeout.js b/examples/timeout.js
@@ -4,7 +4,7 @@ const { timeout } = require("../build");
 
 timeout(
   300,
-  resolveAfter
+  resolveAfter,
 )(5000)
   .then(() => console.log("Will not be called"))
   .catch(console.error);

diff --git a/examples/timeout.ts b/examples/timeout.ts
@@ -2,7 +2,7 @@ import { timeout } from "../lib";
 
 timeout(
   300,
-  resolveAfter
+  resolveAfter,
 )(5000)
   .then(() => console.log("Will not be called"))
   .catch(console.error);

diff --git a/examples/timeoutWithOptions.js b/examples/timeoutWithOptions.js
@@ -5,7 +5,7 @@ const { timeoutWithOptions } = require("../build");
 timeoutWithOptions(
   300,
   { createError },
-  resolveAfter
+  resolveAfter,
 )(5000)
   .then(() => console.log("Will not be called"))
   .catch(console.error);

diff --git a/examples/timeoutWithOptions.ts b/examples/timeoutWithOptions.ts
@@ -3,7 +3,7 @@ import { timeoutWithOptions } from "../lib";
 timeoutWithOptions(
   300,
   { createError },
-  resolveAfter
+  resolveAfter,
 )(5000)
   .then(() => console.log("Will not be called"))
   .catch(console.error);

diff --git a/examples/wrap.ts b/examples/wrap.ts
@@ -3,7 +3,7 @@ import { wrap } from "../lib";
 const parse = wrap(JSON.parse);
 
 parse('{"message": "ok"}').then((o: { message: string }) =>
-  console.log(o.message)
+  console.log(o.message),
 ); // ok
 
 parse("[}").catch((e: Error) => console.error(e.message)); // Unexpected token...
diff --git a/lib/operations/compose.spec.ts b/lib/operations/compose.spec.ts
@@ -91,7 +91,7 @@ describe("Compose", () => {
 
     return globalPromise.then(
       () => Promise.reject(new Error("Should fail")),
-      (rejection) => expect(rejection.message).toEqual("bleh")
+      (rejection) => expect(rejection.message).toEqual("bleh"),
     );
   });
 

diff --git a/lib/operations/compose.ts b/lib/operations/compose.ts
@@ -2,7 +2,7 @@ import { AnyFunction } from "../types";
 import { wrap } from "./wrap";
 
 export function compose(
-  functions: AnyFunction[] = []
+  functions: AnyFunction[] = [],
 ): (...args: any[]) => Promise<any> {
   if (functions.length === 0) {
     return (x) => Promise.resolve(x);

diff --git a/lib/operations/delay.ts b/lib/operations/delay.ts
@@ -7,22 +7,22 @@ import {
 
 function rawDelay<F extends AnyFunction>(
   milliseconds: number,
-  func: F
+  func: F,
 ): PromisifiedFunction<F> {
   return (...args: Parameters<F>) =>
     new Promise((resolve) => setTimeout(resolve, milliseconds)).then(() =>
-      func(...args)
+      func(...args),
     ) as PromisifiedReturnType<F>;
 }
 
 const curriedDelay = autoCurry(rawDelay);
 
 export function delay<F extends AnyFunction>(
   milliseconds: number,
-  func: F
+  func: F,
 ): PromisifiedFunction<F>;
 export function delay<F extends AnyFunction>(
-  milliseconds: number
+  milliseconds: number,
 ): (func: F) => PromisifiedFunction<F>;
 export function delay<F extends AnyFunction>(
   ...args: any[]

diff --git a/lib/operations/map.spec.ts b/lib/operations/map.spec.ts
@@ -53,12 +53,12 @@ describe("Map with options", () => {
     const globalPromise = mapWithOptions(
       rejectFor2,
       { concurrency: 3 },
-      [1, 2, 3]
+      [1, 2, 3],
     );
 
     return globalPromise.then(
       () => Promise.reject(new Error("Should fail")),
-      (rejection: Error) => expect(rejection.message).toEqual("bleh")
+      (rejection: Error) => expect(rejection.message).toEqual("bleh"),
     );
 
     function rejectFor2(x: number) {
@@ -70,12 +70,12 @@ describe("Map with options", () => {
     const globalPromise = mapWithOptions(
       rejectForGreaterThan2,
       { concurrency: 3 },
-      [1, 2, 3]
+      [1, 2, 3],
     );
 
     return globalPromise.then(
       () => Promise.reject(new Error("Should fail")),
-      (rejection: Error) => expect(rejection.message).toEqual("bleh2")
+      (rejection: Error) => expect(rejection.message).toEqual("bleh2"),
     );
 
     function rejectForGreaterThan2(x: number) {
@@ -97,7 +97,7 @@ describe("Map with options", () => {
     const globalPromise = mapWithOptions(
       (f) => f(),
       { concurrency: 4 },
-      functions
+      functions,
     );
 
     return globalPromise.then(() => {

diff --git a/lib/operations/map.ts b/lib/operations/map.ts
@@ -7,7 +7,7 @@ interface Options {
 function rawMapWithOptions<T1, T2>(
   func: (v: T1) => T2 | Promise<T2>,
   options: Options,
-  values: T1[]
+  values: T1[],
 ): Promise<T2[]> {
   const opts = Object.assign({}, { concurrency: 3 }, options);
   return doRawMapWithOptions(wrap(func), opts, values);
@@ -16,7 +16,7 @@ function rawMapWithOptions<T1, T2>(
 function doRawMapWithOptions<T1, T2>(
   func: (v: T1) => Promise<T2>,
   options: Required<Options>,
-  values: T1[]
+  values: T1[],
 ): Promise<T2[]> {
   if (values.length === 0) {
     return Promise.resolve([]);
@@ -77,10 +77,10 @@ const curriedMapWithOptions = autoCurry(rawMapWithOptions);
 export function mapWithOptions<T1, T2>(
   func: (v: T1) => T2 | Promise<T2>,
   options: Options,
-  values: T1[]
+  values: T1[],
 ): Promise<T2[]>;
 export function mapWithOptions<T1, T2>(
-  func: (v: T1) => T2 | Promise<T2>
+  func: (v: T1) => T2 | Promise<T2>,
 ): (options: Options) => (values: T1[]) => Promise<T2[]>;
 export function mapWithOptions<T1, T2>(
   ...args: any[]
@@ -90,7 +90,7 @@ export function mapWithOptions<T1, T2>(
 
 function rawMap<T1, T2>(
   func: (v: T1) => T2 | Promise<T2>,
-  values: T1[]
+  values: T1[],
 ): Promise<T2[]> {
   return rawMapWithOptions(func, {}, values);
 }
@@ -99,10 +99,10 @@ const curriedMap = autoCurry(rawMap);
 
 export function map<T1, T2>(
   func: (v: T1) => T2 | Promise<T2>,
-  values: T1[]
+  values: T1[],
 ): Promise<T2[]>;
 export function map<T1, T2>(
-  func: (v: T1) => T2 | Promise<T2>
+  func: (v: T1) => T2 | Promise<T2>,
 ): (values: T1[]) => Promise<T2[]>;
 export function map<T1, T2>(
   ...args: any[]
@@ -112,7 +112,7 @@ export function map<T1, T2>(
 
 function rawMapSeries<T1, T2>(
   func: (v: T1) => T2 | Promise<T2>,
-  values: T1[]
+  values: T1[],
 ): Promise<T2[]> {
   return rawMapWithOptions(func, { concurrency: 1 }, values);
 }
@@ -121,10 +121,10 @@ const curriedMapSeries = autoCurry(rawMapSeries);
 
 export function mapSeries<T1, T2>(
   func: (v: T1) => T2 | Promise<T2>,
-  values: T1[]
+  values: T1[],
 ): Promise<T2[]>;
 export function mapSeries<T1, T2>(
-  func: (v: T1) => T2 | Promise<T2>
+  func: (v: T1) => T2 | Promise<T2>,
 ): (values: T1[]) => Promise<T2[]>;
 export function mapSeries<T1, T2>(
   ...args: any[]

diff --git a/lib/operations/pipe.ts b/lib/operations/pipe.ts
@@ -2,7 +2,7 @@ import { AnyFunction } from "../types";
 import { compose } from "./compose";
 
 export function pipe(
-  functions: AnyFunction[] = []
+  functions: AnyFunction[] = [],
 ): (...args: any[]) => Promise<any> {
   return compose(functions.slice().reverse());
 }