feat: pipeLazy (marpple#218)

src/Lazy/index.ts

@@ -20,6 +20,7 @@ import intersectionBy from "./intersectionBy";
 import keys from "./keys";
 import map from "./map";
 import peek from "./peek";
+import pipeLazy from "./pipeLazy";
 import pluck from "./pluck";
 import prepend from "./prepend";
 import range from "./range";
@@ -64,6 +65,7 @@ export {
   keys,
   map,
   peek,
+  pipeLazy,
   pluck,
   prepend,
   range,

src/Lazy/pipeLazy.ts

@@ -0,0 +1,333 @@
+import pipe1 from "../pipe1";
+import reduce from "../reduce";
+import type Awaited from "../types/Awaited";
+import type ReturnPipeType from "../types/ReturnPipeType";
+
+/**
+ * Make function, that performs left to right function composition.
+ * All arguments must be unary.
+ *
+ * @example
+ * ```ts
+ * pipeLazy(
+ *  map(a => a + 10),
+ *  filter(a => a % 2 === 0),
+ *  toArray,
+ * )([1, 2, 3, 4, 5]); // [12, 14]
+ *
+ * await pipeLazy(
+ *  map(a => a + 10),
+ *  filter(a => a % 2 === 0),
+ *  toArray,
+ * )(Promise.resolve([1, 2, 3, 4, 5])); // [12, 14]
+ *
+ * // if you want to use asynchronous callback
+ * await pipeLazy(
+ *  toAsync,
+ *  map(async (a) => a + 10),
+ *  filter((a) => a % 2 === 0),
+ *  toArray,
+ * )(Promise.resolve([1, 2, 3, 4, 5])); // [12, 14]
+ *
+ * // with toAsync
+ * await pipeLazy(
+ *  toAsync,
+ *  map(a => a + 10),
+ *  filter(a => a % 2 === 0),
+ *  toArray,
+ * )([Promise.resolve(1), Promise.resolve(2), Promise.resolve(3), Promise.resolve(4), Promise.resolve(5)]); // [12, 14]
+ * ```
+ *
+ * {@link https://codesandbox.io/s/fxts-toarray-fy84i | Try It}
+ *
+ * see {@link https://fxts.dev/docs/pipeLazy | pipeLazy}, {@link https://fxts.dev/docs/toAsync | toAsync},
+ * {@link https://fxts.dev/docs/map | map}, {@link https://fxts.dev/docs/filter | filter}
+ */
+// eslint-disable-next-line
+// @ts-ignore
+// prettier-ignore
+function pipeLazy<T1, R>(
+  f1: (a: Awaited<T1>) => R
+): (a: T1) => ReturnPipeType<[T1,R]>;
+
+// prettier-ignore
+function pipeLazy<T1, T2, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => R
+): (a: T1) => ReturnPipeType<[T1, T2, R]>;
+
+function pipeLazy<T1, T2, T3, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => R,
+): (a: T1) => ReturnPipeType<[T1, T2, T3, R]>;
+
+function pipeLazy<T1, T2, T3, T4, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => T4,
+  f4: (a: Awaited<T4>) => R,
+): (a: T1) => ReturnPipeType<[T1, T2, T3, T4, R]>;
+
+function pipeLazy<T1, T2, T3, T4, T5, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => T4,
+  f4: (a: Awaited<T4>) => T5,
+  f5: (a: Awaited<T5>) => R,
+): (a: T1) => ReturnPipeType<[T1, T2, T3, T4, T5, R]>;
+
+function pipeLazy<T1, T2, T3, T4, T5, T6, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => T4,
+  f4: (a: Awaited<T4>) => T5,
+  f5: (a: Awaited<T5>) => T6,
+  f6: (a: Awaited<T6>) => R,
+): (a: T1) => ReturnPipeType<[T1, T2, T3, T4, T5, T6, R]>;
+
+function pipeLazy<T1, T2, T3, T4, T5, T6, T7, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => T4,
+  f4: (a: Awaited<T4>) => T5,
+  f5: (a: Awaited<T5>) => T6,
+  f6: (a: Awaited<T6>) => T7,
+  f7: (a: Awaited<T7>) => R,
+): (a: T1) => ReturnPipeType<[T1, T2, T3, T4, T5, T6, T7, R]>;
+
+function pipeLazy<T1, T2, T3, T4, T5, T6, T7, T8, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => T4,
+  f4: (a: Awaited<T4>) => T5,
+  f5: (a: Awaited<T5>) => T6,
+  f6: (a: Awaited<T6>) => T7,
+  f7: (a: Awaited<T7>) => T8,
+  f8: (a: Awaited<T8>) => R,
+): (a: T1) => ReturnPipeType<[T1, T2, T3, T4, T5, T6, T7, T8, R]>;
+
+function pipeLazy<T1, T2, T3, T4, T5, T6, T7, T8, T9, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => T4,
+  f4: (a: Awaited<T4>) => T5,
+  f5: (a: Awaited<T5>) => T6,
+  f6: (a: Awaited<T6>) => T7,
+  f7: (a: Awaited<T7>) => T8,
+  f8: (a: Awaited<T8>) => T9,
+  f9: (a: Awaited<T9>) => R,
+): (a: T1) => ReturnPipeType<[T1, T2, T3, T4, T5, T6, T7, T8, T9, R]>;
+
+function pipeLazy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => T4,
+  f4: (a: Awaited<T4>) => T5,
+  f5: (a: Awaited<T5>) => T6,
+  f6: (a: Awaited<T6>) => T7,
+  f7: (a: Awaited<T7>) => T8,
+  f8: (a: Awaited<T8>) => T9,
+  f9: (a: Awaited<T9>) => T10,
+  f10: (a: Awaited<T10>) => R,
+): (a: T1) => ReturnPipeType<[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, R]>;
+
+function pipeLazy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => T4,
+  f4: (a: Awaited<T4>) => T5,
+  f5: (a: Awaited<T5>) => T6,
+  f6: (a: Awaited<T6>) => T7,
+  f7: (a: Awaited<T7>) => T8,
+  f8: (a: Awaited<T8>) => T9,
+  f9: (a: Awaited<T9>) => T10,
+  f10: (a: Awaited<T10>) => T11,
+  f11: (a: Awaited<T11>) => R,
+): (a: T1) => ReturnPipeType<[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, R]>;
+
+function pipeLazy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => T4,
+  f4: (a: Awaited<T4>) => T5,
+  f5: (a: Awaited<T5>) => T6,
+  f6: (a: Awaited<T6>) => T7,
+  f7: (a: Awaited<T7>) => T8,
+  f8: (a: Awaited<T8>) => T9,
+  f9: (a: Awaited<T9>) => T10,
+  f10: (a: Awaited<T10>) => T11,
+  f11: (a: Awaited<T11>) => T12,
+  f12: (a: Awaited<T12>) => R,
+): () => ReturnPipeType<[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, R]>;
+
+function pipeLazy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => T4,
+  f4: (a: Awaited<T4>) => T5,
+  f5: (a: Awaited<T5>) => T6,
+  f6: (a: Awaited<T6>) => T7,
+  f7: (a: Awaited<T7>) => T8,
+  f8: (a: Awaited<T8>) => T9,
+  f9: (a: Awaited<T9>) => T10,
+  f10: (a: Awaited<T10>) => T11,
+  f11: (a: Awaited<T11>) => T12,
+  f12: (a: Awaited<T12>) => T13,
+  f13: (a: Awaited<T13>) => R,
+): () => ReturnPipeType<
+  [T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, R]
+>;
+
+// prettier-ignore
+function pipeLazy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => T4,
+  f4: (a: Awaited<T4>) => T5,
+  f5: (a: Awaited<T5>) => T6,
+  f6: (a: Awaited<T6>) => T7,
+  f7: (a: Awaited<T7>) => T8,
+  f8: (a: Awaited<T8>) => T9,
+  f9: (a: Awaited<T9>) => T10,
+  f10: (a: Awaited<T10>) => T11,
+  f11: (a: Awaited<T11>) => T12,
+  f12: (a: Awaited<T12>) => T13,
+  f13: (a: Awaited<T13>) => T14,
+  f14: (a: Awaited<T14>) => R,
+): (a: T1) => ReturnPipeType<[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, R]>;
+
+// prettier-ignore
+function pipeLazy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => T4,
+  f4: (a: Awaited<T4>) => T5,
+  f5: (a: Awaited<T5>) => T6,
+  f6: (a: Awaited<T6>) => T7,
+  f7: (a: Awaited<T7>) => T8,
+  f8: (a: Awaited<T8>) => T9,
+  f9: (a: Awaited<T9>) => T10,
+  f10: (a: Awaited<T10>) => T11,
+  f11: (a: Awaited<T11>) => T12,
+  f12: (a: Awaited<T12>) => T13,
+  f13: (a: Awaited<T13>) => T14,
+  f14: (a: Awaited<T14>) => T15,
+  f15: (a: Awaited<T15>) => R,
+): (a: T1) => ReturnPipeType<[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, R]>;
+
+// prettier-ignore
+function pipeLazy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => T4,
+  f4: (a: Awaited<T4>) => T5,
+  f5: (a: Awaited<T5>) => T6,
+  f6: (a: Awaited<T6>) => T7,
+  f7: (a: Awaited<T7>) => T8,
+  f8: (a: Awaited<T8>) => T9,
+  f9: (a: Awaited<T9>) => T10,
+  f10: (a: Awaited<T10>) => T11,
+  f11: (a: Awaited<T11>) => T12,
+  f12: (a: Awaited<T12>) => T13,
+  f13: (a: Awaited<T13>) => T14,
+  f14: (a: Awaited<T14>) => T15,
+  f15: (a: Awaited<T15>) => T16,
+  f16: (a: Awaited<T16>) => R,
+): (a: T1) => ReturnPipeType<[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, R]>;
+
+// prettier-ignore
+function pipeLazy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => T4,
+  f4: (a: Awaited<T4>) => T5,
+  f5: (a: Awaited<T5>) => T6,
+  f6: (a: Awaited<T6>) => T7,
+  f7: (a: Awaited<T7>) => T8,
+  f8: (a: Awaited<T8>) => T9,
+  f9: (a: Awaited<T9>) => T10,
+  f10: (a: Awaited<T10>) => T11,
+  f11: (a: Awaited<T11>) => T12,
+  f12: (a: Awaited<T12>) => T13,
+  f13: (a: Awaited<T13>) => T14,
+  f14: (a: Awaited<T14>) => T15,
+  f15: (a: Awaited<T15>) => T16,
+  f16: (a: Awaited<T16>) => T17,
+  f17: (a: Awaited<T17>) => R,
+): (a: T1) => ReturnPipeType<[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, R]>;
+
+// prettier-ignore
+function pipeLazy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => T4,
+  f4: (a: Awaited<T4>) => T5,
+  f5: (a: Awaited<T5>) => T6,
+  f6: (a: Awaited<T6>) => T7,
+  f7: (a: Awaited<T7>) => T8,
+  f8: (a: Awaited<T8>) => T9,
+  f9: (a: Awaited<T9>) => T10,
+  f10: (a: Awaited<T10>) => T11,
+  f11: (a: Awaited<T11>) => T12,
+  f12: (a: Awaited<T12>) => T13,
+  f13: (a: Awaited<T13>) => T14,
+  f14: (a: Awaited<T14>) => T15,
+  f15: (a: Awaited<T15>) => T16,
+  f16: (a: Awaited<T16>) => T17,
+  f17: (a: Awaited<T17>) => T18,
+  f18: (a: Awaited<T18>) => R,
+): (a: T1) => ReturnPipeType<[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, R]>;
+
+// prettier-ignore
+function pipeLazy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => T4,
+  f4: (a: Awaited<T4>) => T5,
+  f5: (a: Awaited<T5>) => T6,
+  f6: (a: Awaited<T6>) => T7,
+  f7: (a: Awaited<T7>) => T8,
+  f8: (a: Awaited<T8>) => T9,
+  f9: (a: Awaited<T9>) => T10,
+  f10: (a: Awaited<T10>) => T11,
+  f11: (a: Awaited<T11>) => T12,
+  f12: (a: Awaited<T12>) => T13,
+  f13: (a: Awaited<T13>) => T14,
+  f14: (a: Awaited<T14>) => T15,
+  f15: (a: Awaited<T15>) => T16,
+  f16: (a: Awaited<T16>) => T17,
+  f17: (a: Awaited<T17>) => T18,
+  f18: (a: Awaited<T18>) => T19,
+  f19: (a: Awaited<T19>) => R,
+): (a: T1) => ReturnPipeType<[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, R]>;
+
+// prettier-ignore
+function pipeLazy<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, R>(
+  f1: (a: Awaited<T1>) => T2,
+  f2: (a: Awaited<T2>) => T3,
+  f3: (a: Awaited<T3>) => T4,
+  f4: (a: Awaited<T4>) => T5,
+  f5: (a: Awaited<T5>) => T6,
+  f6: (a: Awaited<T6>) => T7,
+  f7: (a: Awaited<T7>) => T8,
+  f8: (a: Awaited<T8>) => T9,
+  f9: (a: Awaited<T9>) => T10,
+  f10: (a: Awaited<T10>) => T11,
+  f11: (a: Awaited<T11>) => T12,
+  f12: (a: Awaited<T12>) => T13,
+  f13: (a: Awaited<T13>) => T14,
+  f14: (a: Awaited<T14>) => T15,
+  f15: (a: Awaited<T15>) => T16,
+  f16: (a: Awaited<T16>) => T17,
+  f17: (a: Awaited<T17>) => T18,
+  f18: (a: Awaited<T18>) => T19,
+  f19: (a: Awaited<T19>) => T20,
+  f20: (a: Awaited<T20>) => R,
+): (a: T1) => ReturnPipeType<[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, R]>;
+
+function pipeLazy(...fns: any[]) {
+  return (a: any) => reduce(pipe1, a, fns);
+}
+
+export default pipeLazy;