由于未满足的特征边界，无法在 std::net::TcpStream 上调用读取

Question

解决方案： 我需要添加“使用 std::io::prelude::*;”到我的代码。我不知道为什么。

我正在尝试从 std::net::TcpStream 读取，但在调用 stream.read(&buf).unwrap 时收到此错误；

结构std::net::TcpStream 存在方法read，但它的 特征界限不满足 方法不能被调用 std::net::TcpStream 由于不满足的特征边界注意： 不满足以下特征界限： std::net::TcpStream: futures::AsyncRead std::net::TcpStream: futures::AsyncReadExt 需要的帮助：来自特质的项目只有在 特征在 scoperustc(E0599) main.rs(31, 16) 中：无法调用方法 由于 tcp.rs(49, 1): 不满足std::net::TcpStream: futures::AsyncReadExt tcp.rs(49, 1): 不满足std::net::TcpStream: futures::AsyncRead mod.rs(580, 8): 该方法可用于 std::boxed::Box<std::net::TcpStream>这里

代码：

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 中编写代码，但我不知道 rust 是否有不同的处理方式。它也因“async fn connect...”和“fn connect...”而失败。

Answer 1

编译器告诉你解决方案：

帮助：只有当 trait 在范围内时，才能使用来自 trait 的项目

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

use futures::{AsyncRead, AsyncReadExt};

您可能还想使用异步的tokio::TcpStream，而不是std。