This commit is contained in:
wrk 2023-06-09 02:10:42 +02:00
parent 72a97e296b
commit 14682b4481

View File

@ -651,8 +651,11 @@ async fn recv<T: AsyncRead>(
let buf = &buf[..bytes_read]; let buf = &buf[..bytes_read];
*partial_line += String::from_utf8_lossy(buf).into_owned().as_str(); let buf_str: String =
let new_lines: Vec<&str> = partial_line.split("\r\n").collect(); partial_line.to_owned() + String::from_utf8_lossy(buf).into_owned().as_str();
*partial_line = String::new();
let new_lines: Vec<&str> = buf_str.split("\r\n").collect();
let len = new_lines.len(); let len = new_lines.len();
for (index, line) in new_lines.into_iter().enumerate() { for (index, line) in new_lines.into_iter().enumerate() {