diff --git a/crates/core/src/watcher/file_watcher.rs b/crates/core/src/watcher/file_watcher.rs index 4420068..795be03 100644 --- a/crates/core/src/watcher/file_watcher.rs +++ b/crates/core/src/watcher/file_watcher.rs @@ -62,7 +62,7 @@ impl FileWatcher { match event.kind { EventKind::Modify(_) | EventKind::Create(_) | EventKind::Any => {} EventKind::Remove(_) => { - let _ = tx.send(FileEvent::Removed); + let _ = tx.try_send(FileEvent::Removed); return; } _ => return, @@ -83,19 +83,19 @@ impl FileWatcher { }); if current_inode != 0 && st.last_inode != 0 && current_inode != st.last_inode { - let _ = tx.send(FileEvent::Rotated { + let _ = tx.try_send(FileEvent::Rotated { new_inode: current_inode, }); st.last_inode = current_inode; st.last_size = current_size; } else if current_size > st.last_size { - let _ = tx.send(FileEvent::Appended { + let _ = tx.try_send(FileEvent::Appended { new_size: current_size, }); st.last_size = current_size; st.last_inode = current_inode; } else if current_size < st.last_size { - let _ = tx.send(FileEvent::Truncated { + let _ = tx.try_send(FileEvent::Truncated { new_size: current_size, }); st.last_size = current_size;