import { Effect, Schedule, Stream } from 'effect';
const program = Stream.fromSchedule(Schedule.spaced('1 second')).pipe(
Stream.interruptWhen(Effect.never),
Stream.take(1),
Stream.runCollect,
);
Effect.runPromise(program);
import { Effect, Schedule, Stream } from 'effect';
const program = Stream.fromSchedule(Schedule.spaced('1 second')).pipe(
Stream.interruptWhen(Effect.never),
Stream.take(1),
Stream.runCollect,
);
Effect.runPromise(program);