Struct Thread 

pub struct Thread { /* private fields */ }

A conversation thread with the Codex agent.

Each call to run() or run_streamed() spawns a codex exec subprocess.

Implementations

impl Thread

pub fn with_approval_callback(self, callback: ApprovalCallback) -> Self

Set an approval callback for handling permission requests.

pub fn with_patch_approval_callback( self, callback: PatchApprovalCallback, ) -> Self

Set a patch approval callback for handling file-patch approval requests.

pub fn with_event_callback(self, callback: EventCallback) -> Self

Set an event callback for observing, transforming, or filtering events.

pub fn with_hooks(self, hooks: Vec<HookMatcher>) -> Self

Add hooks to this thread.

pub fn with_transport(self, transport: Arc<dyn Transport>) -> Self

Override the transport used for this thread (useful for testing).

When set, the provided transport is used instead of spawning a real codex subprocess. The same connect / write / end_input / read_messages / close call sequence is used regardless.

pub fn id(&self) -> Option<String>

Get the thread ID (populated after first successful turn).

pub async fn interrupt(&self) -> Result<()>

Interrupt the currently running turn by sending SIGINT to the CLI subprocess.

Equivalent to pressing Ctrl-C. The CLI has close_timeout seconds to clean up before being force-killed. Returns Ok(()) if no turn is in progress.

pub async fn run( &mut self, input: impl Into<Input>, turn_options: TurnOptions, ) -> Result<Turn>

Run a prompt and collect all events into a Turn.

pub async fn run_streamed( &mut self, input: impl Into<Input>, turn_options: TurnOptions, ) -> Result<StreamedTurn>

Run a prompt and return a streaming StreamedTurn.