Function withConnection

packages/plugins/mcp/src/sdk/connection-pool.ts:108–127

(key, connector, use)

    });

  const withConnection: McpConnectionPool["withConnection"] = (key, connector, use) => {
    let reused = false;
    const run = (forceFresh: boolean) =>
      Effect.acquireUseRelease(
        acquire(key, connector, forceFresh),
        (lease) => {
          if (!forceFresh) reused = lease.reused;
          return use(lease.connection);
        },
        (lease, exit) => release(key, lease, exit),
      );

    return run(false).pipe(
      Effect.catch((error) =>
        reused && isMcpInvocationError(error) && error.status === 404
          ? run(true)
          : Effect.fail(error),
      ),
    );
  };

  const close = () =>
    Effect.gen(function* () {