async-std::net::TcpStream的读取函数虽然有数据可用,但却不返回。
创始人
2024-09-21 00:01:22
0

在async-std中,TcpStream.read()函数是非阻塞的,它只会尽力读取尽可能多的数据并立即返回。如果没有数据可用,它将立即返回一个空的结果。

以下是一个使用async-std::net::TcpStream读取函数的示例,其中包括处理可能返回空结果的情况:

use async_std::net::TcpStream;
use async_std::prelude::*;
use std::io::Result;

async fn read_data(stream: &mut TcpStream) -> Result> {
    let mut buffer = vec![0; 1024];
    let mut result = Vec::new();

    loop {
        match stream.read(&mut buffer).await {
            Ok(n) if n == 0 => break, // No more data available, break the loop
            Ok(n) => result.extend_from_slice(&buffer[..n]),
            Err(e) => return Err(e),
        }
    }

    Ok(result)
}

#[async_std::main]
async fn main() -> Result<()> {
    let mut stream = TcpStream::connect("127.0.0.1:8080").await?;
    let data = read_data(&mut stream).await?;
    println!("Received data: {:?}", data);

    Ok(())
}

在这个例子中,read_data()函数使用了一个循环来读取TcpStream中的数据。如果返回的数据长度为0,表示没有更多的数据可用,循环将终止。否则,将数据追加到结果向量中。

通过使用这种循环的方式,可以确保在有数据可用时读取其所有数据,即使TcpStream.read()函数返回一个空的结果。

相关内容

热门资讯

wepoke ai辅助!wep... wepoke ai辅助!wepoke可以使用模拟器,wepok软件透明挂,攻略教程(有挂技巧)1、点...
wepoke辅助挂!wepok... wepoke辅助挂!wepoke有插件,wepOkE总是真的有挂,科技教程(有挂细节);玩家必备必赢...
玩家攻略推荐!天天斗牌大联盟麻... 玩家攻略推荐!天天斗牌大联盟麻将(透明挂)好像真的有挂(2021已更新)(哔哩哔哩)1、构建自己的天...
微扑克有辅助挂!微扑克大厅都是... 微扑克有辅助挂!微扑克大厅都是机器人,德州扑克微扑克俱乐部,系统教程(有挂机密)是一款可以让一直输的...
wepokeai机器人!wep... 这是一款非常优秀的WepOke ia辅助检测软件,能够让你了解到WepOke中牌率当中全部隐藏参数,...
揭秘一下!科乐麻将系统规律(透... 揭秘一下!科乐麻将系统规律(透视)原来是有挂(2026已更新)(哔哩哔哩)1、科乐麻将系统规律系统规...
微扑克有辅助挂!微扑克有后台控... 微扑克有辅助挂!微扑克有后台控制(透明挂)原来真的是有挂1、超多福利:超高返利,海量正版游戏,微扑克...
WePoKe外 挂!wopok... 1、WePoKe外 挂!wopoker有外 挂(透明挂)wEpOke(就是真的有挂);该软件可以轻松...
程序员教你!欢乐划水麻将是不是... 程序员教你!欢乐划水麻将是不是有猫腻(透视辅助)都是有挂(2024已更新)(哔哩哔哩)1、点击下载安...
微扑克系统发牌规律!微扑克有计... 1、微扑克系统发牌规律!微扑克有计算器,微扑克ai软件(确实真的有挂);代表性(透视辅助软件透明挂)...