Function read_json_rpc_request_id

src/daemon.rs:2078–2089

(
    transport: &mut UnixStreamTransport,
)

#[cfg(unix)]
async fn read_json_rpc_request_id(
    transport: &mut UnixStreamTransport,
) -> Result<serde_json::Value> {
    let Some(line) = transport.read_line().await? else {
        return Ok(serde_json::Value::Null);
    };

    Ok(serde_json::from_str::<JsonRpcRequest>(&line)
        .ok()
        .and_then(|request| request.id)
        .unwrap_or(serde_json::Value::Null))
}

#[cfg(unix)]
async fn write_json_rpc_response(