From 9c632725afb73bbf0966e52ca50c6d66c12d853b Mon Sep 17 00:00:00 2001 From: Szymon Szukalski Date: Tue, 2 Oct 2012 21:11:19 +1000 Subject: Re-wrote AsynchronousFileReader. Various clean-ups. --- src/main/java/io/skas/melbjvm/nio2/Watcher.java | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) (limited to 'src/main/java/io/skas/melbjvm/nio2/Watcher.java') diff --git a/src/main/java/io/skas/melbjvm/nio2/Watcher.java b/src/main/java/io/skas/melbjvm/nio2/Watcher.java index 2947ef7..1938c9f 100644 --- a/src/main/java/io/skas/melbjvm/nio2/Watcher.java +++ b/src/main/java/io/skas/melbjvm/nio2/Watcher.java @@ -6,6 +6,9 @@ import org.slf4j.LoggerFactory; import java.io.IOException; import java.nio.file.*; +/** + * @author Szymon Szukalski [szymon.szukalski@gmail.com] + */ public class Watcher { private static final Logger LOG = LoggerFactory.getLogger(Watcher.class); @@ -35,15 +38,15 @@ public class Watcher { final WatchEvent watchEventPath = (WatchEvent) watchEvent; Path newFile = watchedPath.resolve(watchEventPath.context()); - if (kind == StandardWatchEventKinds.ENTRY_MODIFY) { - new FileReader(newFile); + if (kind == StandardWatchEventKinds.ENTRY_CREATE) { + new AsynchronousFileReader(newFile); } } - //reset the key + // reset the key boolean valid = key.reset(); - //exit loop if the key is not valid (if the directory was deleted, for example) + // exit loop if the key is not valid (if the directory was deleted, for example) if (!valid) { break; } -- cgit v1.2.3