Struct ActiveConnection 

pub struct ActiveConnection {
    pub id: u64,
    pub stream: TcpStream,
    pub host: String,
    pub last_used: Instant,
}

活动连接信息

Fields

id: u64

唯一连接 ID

stream: TcpStream

TCP 流

host: String

目标主机

last_used: Instant

最后使用时间

Implementations

impl ActiveConnection

pub fn is_valid(&self) -> bool

检查连接是否仍然有效

pub fn touch(&mut self)

更新最后使用时间

impl ActiveConnection

pub async fn read_with_timeout( &mut self, buf: &mut [u8], read_timeout: Duration, ) -> Result<usize>

异步读取数据（带超时控制）

从 TCP 流中读取数据到缓冲区，受 read_timeout 限制。 用于读取 HTTP 响应头和响应体。

pub async fn write_with_timeout( &mut self, buf: &[u8], write_timeout: Duration, ) -> Result<usize>

异步写入数据（带超时控制）

将数据写入 TCP 流，受 write_timeout 限制。 用于发送 HTTP 请求头和请求体。

pub async fn flush_with_timeout( &mut self, write_timeout: Duration, ) -> Result<()>

刷新写缓冲区（带超时控制）

pub async fn shutdown(&mut self) -> Result<()>

关闭连接（双向关闭）

pub fn peer_addr(&self) -> Result<SocketAddr>

获取对等端地址

pub fn local_addr(&self) -> Result<SocketAddr>

获取本地地址

Trait Implementations

impl Debug for ActiveConnection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.