Function withDependencyCapture

packages/infra/test/rpc-e2e-invalidation.test.ts:254–261

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

  })

const withDependencyCapture = <A, E, R>(eff: Effect.Effect<A, E, R>) =>
  Effect.gen(function*() {
    const readsRef = yield* Ref.make(DataDependencies.empty())
    const writesRef = yield* Ref.make(DataDependencies.empty())
    const svc = DataDependencies.makeDataDependencyRecorder(readsRef, writesRef)
    const result = yield* eff.pipe(Effect.provideService(DataDependencies.DataDependencyRecorder, svc), Effect.exit)
    return { result, dependencies: yield* svc.get }
  })

// ---------------------------------------------------------------------------
// Tests