rust - Rust异步std奇怪的语法以解决读写借用冲突

Question

我试图用async-std编写一个tcp服务器，以解决读写借阅检查的问题，我发现了一种奇怪的方法:

use async_std::prelude::*;
use async_std::task;
use async_std::net::TcpListener;
use async_std::io::BufReader;
fn main() {
    task::block_on(async {
        let listener = TcpListener::bind("0.0.0.0:9000").await.unwrap();
        let mut incoming = listener.incoming();
        while let Some(stream) = incoming.next().await {
            let stream = stream.unwrap();
            println!("Client Addr: {:?}", stream.peer_addr().unwrap());
            task::spawn( async move {
                let (reader, mut writer) = (&stream, &stream); // Stange here <-----
                let reader = BufReader::new(reader);
                let mut lines = reader.lines();
                while let Some(line) = lines.next().await {
                    let mut line = line.unwrap();
                    line.push('x');
                    line.push('\n');
                    writer.write_all(line.as_bytes()).await.unwrap();
                }
            });
        }
    });
}

奇怪的: let (reader, mut writer) = (&stream, &stream); // Stange here <-----我按照这种方法编写了一个验证程序:

fn main() {
    let mut arr = vec![1, 2, 3, 4];
    let (r, mut w) = (&arr, &arr);
    for v in r.iter() {
        if v == &2 {
            w.push(5);
        }
    }
    dbg!(arr);
}

出现错误:

error[E0596]: cannot borrow `*w` as mutable, as it is behind a `&` reference

有人可以解释吗？

Answer 1

这是可行的，因为TcpStream具有以下含义:

impl Read for TcpStream
impl Write for TcpStream
impl<'_> Read for &'_ TcpStream
impl<'_> Write for &'_ TcpStream

前两个是“普通”的，后两个是“特殊”的，它们使您可以执行此读写器技巧。
例如: read() trait方法的定义如下:

pub fn read<'a>(&'a mut self, buf: &'a mut [u8]) -> ImplFuture<Result<usize>> 

当执行 stream.read(buf)时，您正在使用 impl Read for TcpStream impl。因此，您正在使用 self类型为 &mut TcpStream的方法来调用该方法。
当您执行 let reader = &stream; reader.read(buf)时，您正在使用 impl<'_> Read for &'_ TcpStream。因此，您正在使用 self类型为 &mut &TcpStream的方法来调用该方法。