( self: Effect.Effect<A, E, FixEnv<R, W3, S1, S3>>, s: S4 )
| 144 | } |
| 145 | |
| 146 | export 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 | |
| 169 | export function runResult<R, E, A, W3, S1, S3, S4 extends S1>( |
| 170 | self: Effect.Effect<A, E, FixEnv<R, W3, S1, S3>>, |
no test coverage detected
searching dependent graphs…