We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 03f901b commit d6db346Copy full SHA for d6db346
src/sync/pipe.rs
@@ -1,5 +1,6 @@
1
use crate::shared::UnsafeShared;
2
use std::cell::UnsafeCell;
3
+use std::io::BufRead;
4
use std::rc::Rc;
5
use std::task::{Context, Poll, Waker};
6
use std::{cmp, io};
@@ -52,7 +53,7 @@ impl Pipe {
52
53
let (head, tail) = self.buffer.as_slices();
54
let bytes_copied = copy_slice(buf, head) + copy_slice(buf, tail);
55
if bytes_copied > 0 {
- self.buffer.drain(..bytes_copied); // FIXME: replace with truncate_front when stabilized
56
+ self.buffer.consume(bytes_copied);
57
if let Some(waker) = self.write_waker.take() {
58
waker.wake();
59
}
0 commit comments