MCPcopy
hub / github.com/Effect-TS/effect / runCollect

Function runCollect

packages/effect/test/Schedule.test.ts:905–914  ·  view source on GitHub ↗
(
  schedule: Schedule.Schedule<Out, In, Env>,
  input: Iterable<In>
)

Source from the content-addressed store, hash-verified

903 )
904}
905export 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}
915const runCollectLoop = <Env, In, Out>(
916 driver: Schedule.ScheduleDriver<Out, In, Env>,
917 input: Chunk.Chunk<In>,

Callers 1

Schedule.test.tsFile · 0.70

Calls 3

runCollectLoopFunction · 0.85
runFunction · 0.70
pipeMethod · 0.65

Tested by

no test coverage detected