fix bufreader.take usage

This commit is contained in:
galister
2025-12-19 00:50:52 +09:00
parent 4dc8bb0a3a
commit 502c59424e

View File

@@ -38,7 +38,7 @@ impl PipeReaderThread {
let handle = std::thread::spawn({ let handle = std::thread::spawn({
move || { move || {
let stdout = c.stdout.take().unwrap(); let stdout = c.stdout.take().unwrap();
let mut reader = BufReader::new(stdout).take(BUF_LEN as _); let mut reader = BufReader::new(stdout);
loop { loop {
let mut buf = String::with_capacity(BUF_LEN); let mut buf = String::with_capacity(BUF_LEN);
@@ -75,7 +75,7 @@ impl PipeReaderThread {
.inspect_err(|e| { .inspect_err(|e| {
log::warn!("Failed to open fifo: {e:?}"); log::warn!("Failed to open fifo: {e:?}");
}) })
.map(|r| BufReader::new(r).take(BUF_LEN as _)) .map(|r| BufReader::new(r))
else { else {
return false; return false;
}; };