( effect: Effect.Effect<A, E, R> )
| 895 | }) |
| 896 | } |
| 897 | export const run = <A, E, R>( |
| 898 | effect: Effect.Effect<A, E, R> |
| 899 | ): Effect.Effect<A, E, R> => { |
| 900 | return Effect.fork(effect).pipe( |
| 901 | Effect.tap(() => TestClock.setTime(Number.POSITIVE_INFINITY)), |
| 902 | Effect.flatMap(Fiber.join) |
| 903 | ) |
| 904 | } |
| 905 | export const runCollect = <Env, In, Out>( |
| 906 | schedule: Schedule.Schedule<Out, In, Env>, |
| 907 | input: Iterable<In> |
no test coverage detected