iter-ops-test.ts

import {pipeAsync, map, waitRace, delay} from 'iter-ops';

const i = pipeAsync(
    [1, 2, 3],
    map(s => Promise.resolve(s * 10)),
    delay(100),
    waitRace(3)
);

(async function () {
    for await (const a of i) {
        console.log(a);
    }
})();