diff --git a/src/raw_stream.rs b/src/raw_stream.rs
index 948082a..58e2a9d 100644
--- a/src/raw_stream.rs
+++ b/src/raw_stream.rs
@@ -602,6 +602,7 @@ mod tokio_stream {
                 }
 
                 self.device.get_mut().event_buf.clear();
+                self.index = 0;
 
                 loop {
                     let mut guard = ready!(self.device.poll_read_ready_mut(cx))?;