src/download.rs

@@ -288,12 +288,19 @@ where
                         if offset >= *this.available_file_size {
                             trace!("waiting for inotify events");
                             file.get_or_insert(inner_file);
-                            if ready!(this.events.poll_next(cx)).is_none() {
+                            match this.events.poll_next(cx) {
-                                return Poll::Ready(Some(Err(ErrorInternalServerError(
+                                Poll::Pending => {
-                                    "inotify stream empty",
+                                    return Poll::Pending;
-                                ))));
+                                }
+                                Poll::Ready(Some(_)) => {
+                                    return self.poll_next(cx);
+                                }
+                                _ => {
+                                    return Poll::Ready(Some(Err(ErrorInternalServerError(
+                                        "inotify stream empty",
+                                    ))));
+                                }
                             }
-                            return self.poll_next(cx);
                         }
                     }