Function read_byte_until

src/diagnostics/lsp/client.rs:492–524

(
    reader: &mut BufReader<tokio::process::ChildStdout>,
    deadline: tokio::time::Instant,
    partial_message: bool,
    timeouts: LspRefreshTimeouts,
)

}

async fn read_byte_until(
    reader: &mut BufReader<tokio::process::ChildStdout>,
    deadline: tokio::time::Instant,
    partial_message: bool,
    timeouts: LspRefreshTimeouts,
) -> Result<Option<u8>> {
    let now = tokio::time::Instant::now();
    if now >= deadline {
        return if partial_message {
            Err(refresh_timed_out(timeouts))
        } else {
            Ok(None)
        };
    }
    let mut byte = [0_u8; 1];
    match tokio::time::timeout(
        deadline.saturating_duration_since(now),
        reader.read(&mut byte),
    )
    .await
    {
        Ok(Ok(0)) if partial_message => Err(TraceDecayError::Config {
            message: "LSP server closed before completing message header".to_string(),
        }),
        Ok(Ok(0)) => Ok(None),
        Ok(Ok(_)) => Ok(Some(byte[0])),
        Ok(Err(err)) => Err(TraceDecayError::Config {
            message: format!("failed to read LSP header: {err}"),
        }),
        Err(_) if partial_message => Err(refresh_timed_out(timeouts)),
        Err(_) => Ok(None),
    }
}

fn file_uri(path: &Path) -> String {
    let absolute = if path.is_absolute() {