Support async pipe

[4513ECHO]

Currently piping async function to sync function is impossible.

const syncFn = (x) => { ... }
const asyncFn = async (x) => { ... }

await pipe(
  [],
  asyncFn,
  syncFn, // Error because the argument is `Promise<T>`
)

We need jsr:@core/pipe/async or something to support it.

[lambdalisue]

@4513ECHO Could you try pipe in async module of https://jsr.io/@core/[email protected]

[4513ECHO]

It works fine. Thanks!

[lambdalisue]

📝

This was required to combine the following two pipe

import { pipe } from "jsr:@core/pipe";
import { pipe as pipeAsync } from "jsr:@core/pipe/async";
import { toAsyncIterable } from "jsr:@core/iterutil/async/to-async-iterable";
import { map } from "jsr:@core/iterutil/pipe/async/map";

// We must resolve the promise before we can use the value
// in the next pipe function. So that we cannot combine
// the following two pipes into one.
const fst = await pipe(
  toAsyncIterable([1, 2, 3]),
  map((x) => x * 2),
  (v) => Array.fromAsync(v),
);
const snd = pipe(
  fst,
  (v) => v.join(""),
  (v) => v.repeat(2),
);
console.log(snd);

// If we use `pipe/async` instead, we can combine the two pipes
const trd = await pipeAsync(
  toAsyncIterable([1, 2, 3]),
  map((x) => x * 2),
  (v) => Array.fromAsync(v),
  (v) => v.join(""),
  (v) => v.repeat(2),
);
console.log(trd);