itsscb/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2025-10-01 12:20:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

io: use Buf::put_bytes in Repeat read impl (#7055)

Browse Source
This commit is contained in:
Paolo Barbolini 2024-12-30 13:44:55 +01:00 committed by GitHub
parent 9d42b977df
commit b3ff911c38
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tokio/Cargo.toml
View File

@ -91,7 +91,7 @@ tokio-macros = { version = "~2.4.0", path = "../tokio-macros", optional = true }
pin-project-lite = "0.2.11" pin-project-lite = "0.2.11"
# Everything else is optional... # Everything else is optional...
bytes = { version = "1.0.0", optional = true } bytes = { version = "1.1.0", optional = true }
mio = { version = "1.0.1", optional = true, default-features = false } mio = { version = "1.0.1", optional = true, default-features = false }
parking_lot = { version = "0.12.0", optional = true } parking_lot = { version = "0.12.0", optional = true }

7
tokio/src/io/util/repeat.rs
View File

@ -1,3 +1,5 @@
use bytes::BufMut;
use crate::io::util::poll_proceed_and_make_progress; use crate::io::util::poll_proceed_and_make_progress;
use crate::io::{AsyncRead, ReadBuf}; use crate::io::{AsyncRead, ReadBuf};
@ -56,10 +58,7 @@ impl AsyncRead for Repeat {
) -> Poll<io::Result<()>> { ) -> Poll<io::Result<()>> {
ready!(crate::trace::trace_leaf(cx)); ready!(crate::trace::trace_leaf(cx));
ready!(poll_proceed_and_make_progress(cx)); ready!(poll_proceed_and_make_progress(cx));
// TODO: could be faster, but should we unsafe it? buf.put_bytes(self.byte, buf.remaining());
while buf.remaining() != 0 {
buf.put_slice(&[self.byte]);
}
Poll::Ready(Ok(())) Poll::Ready(Ok(()))
} }
} }