stream

ltpp-universe2025年2月23日小于 1 分钟hyperlanewebrust

获取 `stream`

let controller_data = arc_lock_controller_data.get_write_lock().await;
let stream_lock: Arc<TcpStream> = controller_data.get_stream().clone().unwrap();

获取可变 `stream`

通过写锁

let mut controller_data = arc_lock_controller_data.get_write_lock().await;
controller_data.get_mut_stream().and_then(|mut stream| {});

设置 `stream`

let controller_data: ControllerData = arc_lock_controller_data.get_clone().await;
controller_data.set_stream(None);

let mut controller_data = arc_lock_controller_data.get_write_lock().await;
controller_data.set_stream(None);

获取客户端地址

框架封装 get_socket_addr

arc_lock_controller_data.get_socket_addr().await;

手动解析

let controller_data: ControllerData = arc_lock_controller_data.get_clone().await;
let socket_addr: String = stream_lock
    .get_read_lock()
    .await
    .peer_addr()
    .and_then(|host| Ok(host.to_string()))
    .unwrap_or("Unknown".to_owned());