Skip to content

Commit 84b627b

Browse files
committed
Move closed check to handleEvent
1 parent 9b58bc4 commit 84b627b

File tree

1 file changed

+7
-9
lines changed

1 file changed

+7
-9
lines changed

src/main/java/engineering/swat/watch/impl/jdk/JDKDirectoryWatch.java

Lines changed: 7 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -70,14 +70,12 @@ public JDKDirectoryWatch(Path directory, Executor exec,
7070

7171
private void handleJDKEvents(List<java.nio.file.WatchEvent<?>> events) {
7272
exec.execute(() -> {
73-
if (!closed) {
74-
for (var ev : events) {
75-
try {
76-
handleEvent(translate(ev));
77-
}
78-
catch (Throwable ignored) {
79-
logger.error("Ignoring downstream exception:", ignored);
80-
}
73+
for (var ev : events) {
74+
try {
75+
handleEvent(translate(ev));
76+
}
77+
catch (Throwable ignored) {
78+
logger.error("Ignoring downstream exception:", ignored);
8179
}
8280
}
8381
});
@@ -92,7 +90,7 @@ public WatchScope getScope() {
9290

9391
@Override
9492
public void handleEvent(WatchEvent e) {
95-
if (eventFilter.test(e)) {
93+
if (!closed && eventFilter.test(e)) {
9694
eventHandler.accept(this, e);
9795
}
9896
}

0 commit comments

Comments
 (0)