流

eastspire2025年6月2日小于 1 分钟hyperlanewebrustusage-introductionstream

提示

hyperlane 框架接收请求和发送响应均依赖 stream，使用方式如下：

获取 `stream`

let stream_lock: ArcRwLockStream = ctx.get_stream().await.clone().unwrap();

获取客户端地址

提示

完整接口参阅官方文档，此处只介绍通过 stream 解析使用。

let socket_addr: String = ctx
    .get_stream()
    .await
    .unwrap()
    .get_read_lock()
    .await
    .peer_addr()
    .and_then(|host| Ok(host.to_string()))
    .unwrap_or("Unknown".to_owned());