MCPcopy Create free account
hub / github.com/effect-app/libs / runAll

Function runAll

packages/effect-app/src/Pure.ts:146–167  ·  view source on GitHub ↗
(
  self: Effect.Effect<A, E, FixEnv<R, W3, S1, S3>>,
  s: S4
)

Source from the content-addressed store, hash-verified

144}
145
146export function runAll<R, E, A, W3, S1, S3, S4 extends S1>(
147 self: Effect.Effect<A, E, FixEnv<R, W3, S1, S3>>,
148 s: S4
149): Effect.Effect<
150 readonly [Chunk.Chunk<W3>, Result.Result<readonly [S3, A], E>],
151 never,
152 Exclude<R, { env: PureEnv<W3, S1, S3> }>
153> {
154 const a = Effect
155 .flatMap(self, (x) =>
156 (castTag<W3, S1, S3>())
157 .useSync(
158 ({ env: _ }) => ({ log: _.log, state: _.state })
159 )
160 .pipe(
161 Effect.map(
162 ({ log, state }) => tuple(log, Result.succeed(tuple(state, x)))
163 )
164 ))
165 .pipe(Effect.catch((err: any) => tagg.useSync((env) => tuple(env.env.log, Result.fail(err)))))
166 return Effect.provide(a, Layer.succeed(tagg, { env: makePureEnv<W3, S3, S4>(s) as any }) as any) as any
167}
168
169export function runResult<R, E, A, W3, S1, S3, S4 extends S1>(
170 self: Effect.Effect<A, E, FixEnv<R, W3, S1, S3>>,

Callers 3

runResultFunction · 0.70
runTermFunction · 0.70
runAFunction · 0.70

Calls 10

tupleFunction · 0.90
castTagFunction · 0.85
makePureEnvFunction · 0.85
catchMethod · 0.80
pipeMethod · 0.65
useSyncMethod · 0.65
mapMethod · 0.65
succeedMethod · 0.45
failMethod · 0.45
provideMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…