xenofem
/
transbeam
1
0
Fork 0
Code Issues 6 Pull Requests Projects Releases Wiki Activity

clean up LiveFileReader using ready! macro

main
xenofem 2022-05-10 10:13:47 -04:00
parent 2d64f0529c
commit 331a84627a
1 changed files with 5 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/download.rs
View File

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