async generator example with node.js stream pipelines

async-gen-pipeline.example.js

const fs = require('fs');
const path = require('path');
const { pipeline } = require('stream/promises');

async function generateFixtures() {
    await Promise.all([
        generateFooFixture(),
        generateBarFixture(),
        generateCazFixture(),
        //generateDazFixture(),
    ]);
}

async function generateFooFixture() {
    const writer = fs.createWriteStream(config.fixtures.foo.filepath);
    writer.write(['name', 'email', 'age'].join(config.csv.delimiter) + '\n');

    await pipeline(
        async function*() {
            for (let i = 1; i <= config.fixtures.foo.totalRecords; i++) {
                const foo = {
                    name: `foo-${i}`,
                    email: `${i}@foo.com`,
                    age: `${i}`,
                };
                const line = [foo.name, foo.email, foo.age].join(config.csv.delimiter);
                yield line + '\n';
            }
        },
        writer,
    );
}