/** * Creates a stream from a `Schedule` that does not require any further * input. The stream will emit an element for each value output from the * schedule, continuing for as long as the schedule continues. * * @tsplus static effect/core/stream/Stream.Ops fromSchedule */ export function fromSchedule(schedule: Schedule): Stream { return Stream.unwrap( schedule.driver.map((driver) => Stream.repeatEffectMaybe(driver.next(undefined))) ) }