Function runAcpServerWithStream

packages/acp-adapter/src/server.ts:933–945

(
  harness: KimiHarness,
  stream: Stream,
  opts?: {
    agentInfo?: Implementation;
    terminalAuthEnv?: Readonly<Record<string, string>>;
    terminalAuthLegacyCommand?: string;
    slashCommands?: SlashCommandsResolver;
  },
)

 * in-memory pair instead of process stdio.
 */
export async function runAcpServerWithStream(
  harness: KimiHarness,
  stream: Stream,
  opts?: {
    agentInfo?: Implementation;
    terminalAuthEnv?: Readonly<Record<string, string>>;
    terminalAuthLegacyCommand?: string;
    slashCommands?: SlashCommandsResolver;
  },
): Promise<void> {
  const conn = new AgentSideConnection((c) => new AcpServer(harness, c, opts), stream);
  await conn.closed;
}

/**
 * Drive an {@link AcpServer} over Node stdio (or the supplied streams).