(
&mut self,
stream: Resource<DynInputStream>,
len: u64,
)
| 260 | } |
| 261 | |
| 262 | async fn blocking_read( |
| 263 | &mut self, |
| 264 | stream: Resource<DynInputStream>, |
| 265 | len: u64, |
| 266 | ) -> StreamResult<Vec<u8>> { |
| 267 | let len = len.try_into().unwrap_or(usize::MAX); |
| 268 | let bytes = self.get_mut(&stream)?.blocking_read(len).await?; |
| 269 | debug_assert!(bytes.len() <= len); |
| 270 | Ok(bytes.into()) |
| 271 | } |
| 272 | |
| 273 | fn skip(&mut self, stream: Resource<DynInputStream>, len: u64) -> StreamResult<u64> { |
| 274 | let len = len.try_into().unwrap_or(usize::MAX); |