( schedule: Schedule.Schedule<Out, In, Env>, input: Iterable<In> )
| 903 | ) |
| 904 | } |
| 905 | export const runCollect = <Env, In, Out>( |
| 906 | schedule: Schedule.Schedule<Out, In, Env>, |
| 907 | input: Iterable<In> |
| 908 | ): Effect.Effect<Chunk.Chunk<Out>, never, Env> => { |
| 909 | return run( |
| 910 | Schedule.driver(schedule).pipe( |
| 911 | Effect.flatMap((driver) => runCollectLoop(driver, Chunk.fromIterable(input), Chunk.empty())) |
| 912 | ) |
| 913 | ) |
| 914 | } |
| 915 | const runCollectLoop = <Env, In, Out>( |
| 916 | driver: Schedule.ScheduleDriver<Out, In, Env>, |
| 917 | input: Chunk.Chunk<In>, |
no test coverage detected