如果BufReader取得流的所有权,我该如何读取和写入行？

Question

我想从a读取一行TCPStream,再写一行,然后重复.问题是BufReader::new获取我的TCPStream变量的所有权:

let stream = ...; // TCPStream

let reader = BufReader::new(stream); // moved its value

// can't use stream here anymore

什么是简单的解决方案？

Answer 1

let mut stream = ...;
let reader = BufReader::new(&stream);
let writer = BufWriter::new(&stream);

如果我们仔细看一下BufReader::new,我们会看到它需要一个inner类型的参数R,其中R只有任何类型的实现Read:

impl<R: Read> BufReader<R> {
    pub fn new(inner: R) -> BufReader<R> { ... }
}

然后我们看看Read并看到这个实现:

impl<'a> Read for &'a TcpStream

所以我们可以传递对new函数的引用,如下所示:

let reader = BufReader::new(&stream);

我们会做同样BufWriter和Write和会看到,确实有这样实现:

impl<'a> Write for &'a TcpStream

因此,我们可以再次使用不可变引用来创建BufWriter.

Answer 2

你有几种可能性：

我个人建议不要使用 a ，BufReader除非你确实需要缓冲输入；对于单行来说似乎不值得。

否则，如果您完成了缓冲，您可以恢复底层流，如果没有完成，您可以暂时缓冲它。

注意：请注意BufReader缓冲读取，因此当您借用/恢复内部流时，您会短路缓冲的数据；对于阅读来说这是一个问题，就你的情况（写作）来说应该没问题。