stream

获取 stream

let controller_data: ControllerData = get_controller_data(&arc_lock_controller_data).await;
// 手动解析
let stream_lock: ArcRwLockStream = controller_data.get_stream().clone().unwrap();
// 使用库封装的函数
let stream_lock: ArcRwLockStream = get_stream(&arc_lock_controller_data).await.unwrap();
// 读锁
{
    let stream = stream_lock.read().await;
}
// 写锁
{
    let stream = stream_lock.write().await;
}

获取客户端地址

// 省略 server 和 路由处理函数 创建
let controller_data: ControllerData = get_controller_data(&arc_lock_controller_data).await;
let socket_addr: String = stream_lock
    .read()
    .await
    .peer_addr()
    .and_then(|host| Ok(host.to_string()))
    .unwrap_or("Unknown".to_owned());
// 使用 库 封装的函数
let socket_addr: String = get_socket_addr(&arc_lock_controller_data).await.unwrap();

发送 HTTP 完整响应

let controller_data: ControllerData = get_controller_data(&arc_lock_controller_data).await;
let stream = controller_data.get_mut_stream().clone().unwrap();
let mut response = controller_data.get_response().clone();
let _ = response.set_body("\nhello").send(&stream);

发送响应体

let controller_data: ControllerData = get_controller_data(&arc_lock_controller_data).await;
let stream = controller_data.get_mut_stream().clone().unwrap();
let mut response = controller_data.get_response().clone();
let _ = response.set_body("\nhello").send_body(&stream);

支持多次响应

let controller_data: ControllerData = get_controller_data(&arc_lock_controller_data).await;
let stream = controller_data.get_mut_stream().clone().unwrap();
let mut response = controller_data.get_response().clone();
let mut i = 0;
loop {
    if i > 10 {
        break;
    }
    i += 1;
    let _ = response.set_body("\nhello").send_body(&stream).await;
}