Function wait_for_initialize

src/diagnostics/lsp/client.rs:323–334

(reader: &mut BufReader<tokio::process::ChildStdout>)

}

async fn wait_for_initialize(reader: &mut BufReader<tokio::process::ChildStdout>) -> Result<()> {
    loop {
        let Some(message) = read_message(reader).await? else {
            return Err(TraceDecayError::Config {
                message: "LSP server closed before initialize response".to_string(),
            });
        };
        if message.id == Some(json!(1)) {
            return Ok(());
        }
    }
}

async fn write_message(stdin: &mut tokio::process::ChildStdin, value: Value) -> Result<()> {
    let body = serde_json::to_vec(&value).map_err(|e| TraceDecayError::Config {