(schedule: Schedule.Schedule<A, unknown, R>)
| 3226 | |
| 3227 | /** @internal */ |
| 3228 | export const fromSchedule = <A, R>(schedule: Schedule.Schedule<A, unknown, R>): Stream.Stream<A, never, R> => |
| 3229 | pipe( |
| 3230 | Schedule.driver(schedule), |
| 3231 | Effect.map((driver) => repeatEffectOption(driver.next(void 0))), |
| 3232 | unwrap |
| 3233 | ) |
| 3234 | |
| 3235 | /** @internal */ |
| 3236 | export const fromReadableStream: { |
nothing calls this directly
no test coverage detected