Function withCapture

packages/infra/test/rpc-e2e-invalidation.test.ts:246–252

(eff: Effect.Effect<A, E, R>)

// Helper: provide a fresh `InvalidationKeysFromServer` and capture forwarded keys.
const withCapture = <A, E, R>(eff: Effect.Effect<A, E, R>) =>
  Effect.gen(function*() {
    const ref = yield* Ref.make<ReadonlyArray<Invalidation.InvalidationKey>>([])
    const svc = makeInvalidationKeysService(ref)
    const result = yield* eff.pipe(Effect.provideService(InvalidationKeysFromServer, svc), Effect.exit)
    return { result, keys: yield* Ref.get(ref) }
  })

const withDependencyCapture = <A, E, R>(eff: Effect.Effect<A, E, R>) =>
  Effect.gen(function*() {