Function countingProvider

packages/core/sdk/src/executor.test.ts:873–890

(
  calls: { count: number },
  wrapGet?: <A>(run: () => Promise<A>) => Promise<A>,
)

};

const countingProvider = (
  calls: { count: number },
  wrapGet?: <A>(run: () => Promise<A>) => Promise<A>,
) => {
  const store = new Map<string, string>();
  const provider: CredentialProvider = {
    key: ProviderKey.make("memory"),
    writable: true,
    get: (id) =>
      Effect.promise(() => {
        calls.count++;
        const run = async () => store.get(String(id)) ?? null;
        return wrapGet ? wrapGet(run) : run();
      }),
    set: (id, value) => Effect.sync(() => void store.set(String(id), value)),
  };
  return provider;
};

const invokeConcurrencyPlugin = (provider: CredentialProvider) =>
  definePlugin(() => ({