import { Channel, isClosed } from 'channels.ts';

async function main() {
    const chan = new Channel<number>();

    // Closing the channel after 10_000ms
    setTimeout(function() {
        chan.close();
    }, 10_000);

    // Producer routine
    (async function() {
        for (let i = 1; i <= 10; i++) {
            await chan.put(i);
        }
    })();

    // Consumer routine
    (async function() {
        for await (const value of chan) {
            console.log(value);
        }
    })();

    console.log("Waiting for the channel to be closed...");
    await chan.untilClosed();
    console.log("The channel has been closed.");
}

main();

import { Channel, Select, delay } from "channels.ts";

async function main() {
    const tick = new Channel<number>();
    const boom = new Channel<number>();
    const select = new Select();

    // Puts a value on every 100ms
    const i = setInterval(() => {
        tick.put(0);
    }, 100);

    // Puts a value after 1000ms
    const t = setTimeout(() => {
        boom.put(0);
    }, 1000)

    let b = false;
    while (!b) {
        await select
            .caseTake(tick, async () => console.log("tick."))
            .caseTake(boom, async () => {
                console.log("BOOM!");
                b = true;
            })
            .default(async () => {
                console.log("      .");
                await delay(10);
            })
            .end();
    }

    // Close all channels, intervals and timeouts
    tick.close();
    boom.close();
    clearInterval(i);
    clearTimeout(t);

    console.log("Completed")
}

main();

import { WaitGroup, delay } from "channels.ts";

async function worker(id: number): Promise<void> {
    console.log(`Worker ${id} starting...`);
    await delay(id * 1000);
    console.log(`Worker ${id} done`);
}

async function main() {
    const wg = new WaitGroup();

    for (let i = 1; i <= 5; i++) {
        wg.add(1);

        (async function() {
            await worker(i);
            wg.done();
        })();
    }

    console.log("Waiting...");
    await wg.wait();
    console.log("Done");
}

main();