Function wait_for_response

src/sessions/codex_app_server.rs:289–307

(
    line_rx: &mpsc::Receiver<std::io::Result<String>>,
    deadline: Instant,
    id: i64,
)

}

fn wait_for_response(
    line_rx: &mpsc::Receiver<std::io::Result<String>>,
    deadline: Instant,
    id: i64,
) -> Result<Value> {
    loop {
        let line = recv_line(line_rx, deadline)?;
        let value: Value = serde_json::from_str(&line)?;
        if value.get("id").and_then(Value::as_i64) != Some(id) {
            continue;
        }
        if let Some(error) = value.get("error") {
            return Err(TraceDecayError::Config {
                message: format!("codex app-server request {id} failed: {error}"),
            });
        }
        return Ok(value);
    }
}

fn wait_for_turn_summary(
    line_rx: &mpsc::Receiver<std::io::Result<String>>,