Code: Using Effect Library and AbortController in a Scoped Program

import { MError } from '@mjljm/effect-lib';
import { Console, Effect, Stream } from 'effect';
import { watch } from 'node:fs/promises';

const prog1 = Effect.scoped(
    Effect.gen(function* (_) {
        yield* _(Console.log('prog1 started'));
        const controller = yield* _(
            Effect.acquireRelease(Effect.succeed(new AbortController()), (controller) => {
                controller.abort();
                return Console.log('prog1 done and watch killed');
            })
        );
        yield* _(
            Stream.fromAsyncIterable(
                watch('.', { persistent: false, signal: controller.signal }),
                (e) =>
                    new MError.FunctionPort({
                        originalError: e,
                        originalFunctionName: 'fsPromises.watch',
                        moduleName: import.meta.url,
                        libraryName: 'node-effect-lib'
                    })
            ),
            Stream.runForEach(({ eventType, filename }) => Console.log(`eventType:${eventType} filename:${filename}`))
        );
    })
);

const prog2 = Effect.gen(function* (_) {
    yield* _(Console.log('prog2 started'))
    yield* _(Effect.fork(prog1));
    yield* _(Effect.sleep(5000));
    yield* _(Console.log('prog2 ended'))
});

await Effect.runPromise(prog2);

prog2 started
prog1 started
prog2 ended
prog1 done and watch killed

prog2 started
prog1 started
prog2 ended (after 5 seconds)