const main = Effect.gen(function* (_) {
const queue = yield* _(Queue.bounded<number>(1));
yield* _(Stream.runDrain(Stream.fromQueue(queue, { shutdown: true })));
yield* _(Effect.log('queue drained'));
});
await Effect.runPromise(main);
const main = Effect.gen(function* (_) {
const queue = yield* _(Queue.bounded<number>(1));
yield* _(Stream.runDrain(Stream.fromQueue(queue, { shutdown: true })));
yield* _(Effect.log('queue drained'));
});
await Effect.runPromise(main);