Struct CodexAppServer 

pub struct CodexAppServer { /* private fields */ }

Client wrapper around the stdio app-server.

Implementations

impl CodexAppServer

pub async fn start( config: StdioServerConfig, client: ClientInfo, ) -> Result<Self, McpError>

Launch codex app-server, issue initialize, and return a connected handle.

pub async fn start_experimental( config: StdioServerConfig, client: ClientInfo, ) -> Result<Self, McpError>

Launch with capabilities.experimentalApi=true in the initialize handshake.

pub async fn with_capabilities( config: StdioServerConfig, client: ClientInfo, capabilities: Value, ) -> Result<Self, McpError>

Launch with explicit capabilities to send during initialize.

pub async fn thread_start( &self, params: ThreadStartParams, ) -> Result<AppCallHandle, McpError>

Start a new thread (or use a provided ID) via thread/start.

pub async fn thread_resume( &self, params: ThreadResumeParams, ) -> Result<AppCallHandle, McpError>

Resume an existing thread via thread/resume.

pub async fn thread_list( &self, params: ThreadListParams, ) -> Result<ThreadListResponse, McpError>

List threads via thread/list.

pub async fn thread_fork( &self, params: ThreadForkParams, ) -> Result<ThreadForkResponse, McpError>

Fork an existing thread via thread/fork.

pub async fn turn_start( &self, params: TurnStartParams, ) -> Result<AppCallHandle, McpError>

Start a new turn on a thread via turn/start.

pub async fn turn_start_v2( &self, params: TurnStartParamsV2, ) -> Result<AppCallHandle, McpError>

Start a new turn on a thread via turn/start (pinned fork flow subset).

pub async fn select_last_thread_id( &self, cwd: PathBuf, ) -> Result<Option<String>, McpError>

Select the deterministic “last” thread id using thread/list paging and tuple ordering.

pub async fn turn_interrupt( &self, params: TurnInterruptParams, ) -> Result<AppCallHandle, McpError>

Interrupt an active turn via turn/interrupt.

pub fn cancel(&self, request_id: RequestId) -> Result<(), McpError>

Request cancellation for a pending call.

pub async fn shutdown(&self) -> Result<(), McpError>

Gracefully shut down the app-server.