pub async fn run(
client_rx: UnboundedReceiver<ClientConn>,
metadata_slot: Arc<OnceLock<SessionMetadata>>,
agent_socket_path: PathBuf,
open_socket_path: PathBuf,
) -> Result<()>pub async fn run(
client_rx: UnboundedReceiver<ClientConn>,
metadata_slot: Arc<OnceLock<SessionMetadata>>,
agent_socket_path: PathBuf,
open_socket_path: PathBuf,
) -> Result<()>