1 | use crate::{BufRead, Read}; |
2 | |
3 | /// Read is implemented for `&[u8]` by copying from the slice. |
4 | /// |
5 | /// Note that reading updates the slice to point to the yet unread part. |
6 | /// The slice will be empty when EOF is reached. |
7 | impl Read for &[u8] { |
8 | #[inline ] |
9 | async fn read(&mut self, buf: &mut [u8]) -> Result<usize, Self::Error> { |
10 | let amt: usize = core::cmp::min(v1:buf.len(), self.len()); |
11 | let (a: &[u8], b: &[u8]) = self.split_at(mid:amt); |
12 | |
13 | // First check if the amount of bytes we want to read is small: |
14 | // `copy_from_slice` will generally expand to a call to `memcpy`, and |
15 | // for a single byte the overhead is significant. |
16 | if amt == 1 { |
17 | buf[0] = a[0]; |
18 | } else { |
19 | buf[..amt].copy_from_slice(src:a); |
20 | } |
21 | |
22 | *self = b; |
23 | Ok(amt) |
24 | } |
25 | } |
26 | |
27 | impl BufRead for &[u8] { |
28 | #[inline ] |
29 | async fn fill_buf(&mut self) -> Result<&[u8], Self::Error> { |
30 | Ok(*self) |
31 | } |
32 | |
33 | #[inline ] |
34 | fn consume(&mut self, amt: usize) { |
35 | *self = &self[amt..]; |
36 | } |
37 | } |
38 | |