advance-practice1/web-server

[giscus[bot]]

advance-practice1/web-server

https://course.rs/advance-practice1/web-server.html

[mcfd]

问个问题
将take_while()换成filter()之后 无法返回html
这是为啥?

[SlowSlicing]

你没法返回html和是不是使用 take_while 应该没关系。
take_while：带中断效果，碰到第一个 false，后边的就不继续迭代了，第一个 false 之前的收集起来。
filter：把迭代器中的所有项都迭代一边，为 true 的收集起来。

[ly2020888]

换成filter()之后对stream中进行了更多的读取，导致stream卡住了？再往这个stream写的时候堵塞了所以迟迟不返回吗，有大佬验证一下我的猜测吗

[ly2020888]

哦，也许是用filter没读完，但是为什么呢？

[small-white0-0]

不使用filter或者take_while，会导致请求卡住。应该是因为BufReader的line会返回一个无穷的迭代，然后就会卡在这一步。直到浏览器取消，强制中断，才会继续后面的。

我的理解是：使用take_while可以中断迭代，而filter,不会中断迭代，只是把false的选项排除，然后继续迭代，就永远不会终止，或者浏览器主动断开。由于Stream的中断，让Line迭代器结束。

[luguanqing]

我自己尝试了一下的确会阻塞,不过×掉客户端后就能继续下去了,没有找到原因只能问一下AI了,下面是AI的回答:"filter() 方法看起来像是阻塞的，这是因为它正在等待 BufReader 的 lines() 方法产生更多的行。lines() 方法会一直读取输入，直到遇到 EOF（文件结束标记）或者出现错误。

在你的情况中，你正在从一个 TCP 流中读取数据，这个流可能会一直开放，除非客户端关闭连接或者出现错误。因此，如果客户端发送了一些数据，然后停止发送但没有关闭连接，lines() 方法会一直等待更多的数据，这就是为什么 filter() 看起来像是阻塞的。

如果你想在读取一定数量的行后停止，你可以使用 take() 或 take_while() 方法，而不是 filter()。例如，你可以使用 take_while() 来读取直到遇到一个空行"

[killdayu]

use std::{
    io::{prelude::*, BufReader},
    net::{TcpListener, TcpStream},
};

fn main() {
    let listener = TcpListener::bind("127.0.0.1:7878").unwrap();

    for stream in listener.incoming() {
        let stream = stream.unwrap();

        handle_connection(stream);
    }
}

fn handle_connection(mut stream: TcpStream) {
    let buf_reader = BufReader::new(&mut stream);
    let http_request: Vec<_> = buf_reader
        .lines()
        .map(|result| result.unwrap())
        .take_while(|line| !line.is_empty())
        .collect();

    println!("Request: {:#?}", http_request);
}

stream不是不可变的吗，怎么能当成可变传入函数里面

[Hoyt2256]

因为所有权被转移到handle_connection()里了。

[killdayu]

好吧，我还是第一次在这本书里面看见这样写

[WqVoon]

好奇在我 rustc 1.73.0 的版本下，这段代码的 let buf_reader = BufReader::new(&mut stream) 中将 stream 的可变借用换成不可变借用后依然可以通过编译；但是我看 TcpStream 实现 Read 这个 trait 时方法的第一个参数都是可变借用诶。。。为啥传个不可变借用也能编译过呢

[WqVoon]

发现是因为 TcpStream 为自己和自己的不可变借用都实现了 Read，所以给 BufReader::new() 传递 TcpStream 或 &TcpStream 都是可以的，不过这里传递的是 &mut TcpStream，感觉这反而有问题了🤔️

[WqVoon]

原来 Read 自动实现了 impl<R: Read + ?Sized> Read for &mut R，哎这也太绕了😑

[noCatGo]

请教个问题：
环境为： vscode + RA
有一些库代码能跳转，比如 std::env, std::fs
但有些库代码无法跳转，比如本章中的 std::net::TcpListener
这种问题该如何处理