We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3d90045 commit 00bb9b0Copy full SHA for 00bb9b0
src/imap_stream.rs
@@ -291,6 +291,13 @@ impl<R: Read + Write + Unpin> Stream for ImapStream<R> {
291
this.buffer.ensure_capacity(this.decode_needs)?;
292
let buf = this.buffer.free_as_mut_slice();
293
294
+ // The buffer should have at least one byte free
295
+ // before we try reading into it
296
+ // so we can treat 0 bytes read as EOF.
297
+ // This is guaranteed by `ensure_capacity()` above
298
+ // even if it is called with 0 as an argument.
299
+ debug_assert!(buf.len() > 0);
300
+
301
#[cfg(feature = "runtime-async-std")]
302
let num_bytes_read = ready!(Pin::new(&mut this.inner).poll_read(cx, buf))?;
303
0 commit comments