由于未满足特征界限，无法在std::net::TcpStream上调用read

Question

解决方案:我需要添加“使用std::io::prelude::*”我的准则。我不知道为什么。

我试图从d::网络读取::TcpStream，但我收到这个错误，当调用stream.read（

对于结构 std：：net：：TcpStream 存在读取方法，但其特征边界未得到满足，由于未满足的特性边界，无法在 std：：net：：TcpStream 上调用方法 注意：未满足以下特征边界：std：：net：：TcpStream： futures：：AsyncRead 这是 std：：net：：TcpStream： futures：TsyncLex： futures：：AsyncRead help： 仅当特征处于 scoperustc（E0599） main.rs（31， 16）： 方法不能在 std：：net：：TcpStream 上调用，因为未满足的特质边界 tcp.rs（49， 1）： 不满足 std：：net：：TcpStream： futures：：AsyncReadExt tcp.rs（49， 1）： 不满足 std：：net：：TcpStream： futures：：AsyncRead mod.rs（580， 8）： 该方法可用于 std：：框：：框

代码：

use irc::client::prelude::*;
use futures::prelude::*;
use std::net::{IpAddr, Ipv4Addr, SocketAddr, TcpStream};
use std::io;
use futures::{AsyncRead, AsyncReadExt};

const NAME: &str = "nickname";

#[derive(Debug)]
struct DCC {
    ip: IpAddr,
    port: u16,
}

impl DCC {
    fn from_msg(msg: &str) -> Result<DCC, std::num::ParseIntError> {
        let msg_split: Vec<&str> = msg.split_whitespace().collect();
        let ip: u32 = msg_split[3].parse()?;
        let ip_addr: IpAddr = IpAddr::V4(Ipv4Addr::from(ip));
        let port_num: u16 = msg_split[4].parse()?;
        let dcc = DCC{
           ip: ip_addr,
           port: port_num,
        };
        return Ok(dcc);
    }
    async fn connect(&self) -> Result<(), io::Error>{
        let socket_addr = SocketAddr::new(self.ip, self.port);
        let mut socket = TcpStream::connect(socket_addr)?;
        let mut buf = vec![];
        socket.read(&buf).unwrap();
        return Err(io::Error::new(io::ErrorKind::Other, "oh no!"));
    }
}

#[tokio::main]
async fn irc_get(name: &str) -> Result<String, irc::error::Error>{
    let config = Config {
        nickname: Some(NAME.to_owned()),
        server: Some("irc.irchighway.net".to_owned()),
        port: Some(6667),
        use_tls: Some(false),
        channels: vec!["#ebooks".to_owned()],
        ..Config::default()
    };
    let mut client = Client::from_config(config).await?;
    client.identify()?;

    
    let mut stream = client.stream()?;

    //waits for server to log us in and then sends the search request
    loop{ 
        let m = match stream.next().await{
            Some(v) => v,
            None => panic!("at the disco")
        };
        let message = match &m {
                 Ok(message) => match &message.command {Command::NOTICE(_s1, s2)=> {print!("{:?} \n", s2); message}, _ => message},
                Err(_e) => panic!("at the disco")};
        match &message.command{
            Command::NOTICE(_s, msg) => { if msg.contains("Welcome to #ebooks"){break}}, 
            _=> ()    
        }          
    }
    client.send_privmsg("#ebooks", format!["@Search {}", name])?;
    loop{
        let m = match stream.next().await.transpose()?{
            Some(m) => m,
            None => panic!("at the disco")
        };
        match &m.command{
            Command::PRIVMSG(nm, msg) => if nm == NAME {println!("{:?}",m); return Ok(String::from(msg))},
            _ => ()
        }
    }
}


fn main() {
    let dcc = DCC::from_msg(&irc_get(&"romeo and juliet").unwrap()[..]);
    println!("{:?}", dcc);
}

我对 rust 相当陌生，根据文档中的所有示例，我认为我正确地使用了 .read。我唯一的想法是，也许是因为我试图在impl中编写代码，但我不知道生锈是否以不同的方式对待它。它还会失败，并显示“异步 fn 连接...”并使用“fn connect...”。




Answer 1

编译器告诉你解决方案：

帮助:特性中的物品只有在特性在范围内时才能使用

您需要导入特征才能使用它们：

use futures::{AsyncRead, AsyncReadExt};

此外，您可能希望使用tokio:：TcpStream，它是异步的，而不是std的。