Skip to content

Commit c33f915

Browse files
committed
Added convenience overload
1 parent 4766da6 commit c33f915

File tree

2 files changed

+68
-0
lines changed

2 files changed

+68
-0
lines changed
Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
/*
2+
* BSD 2-Clause License
3+
*
4+
* Copyright (c) 2023, Swat.engineering
5+
*
6+
* Redistribution and use in source and binary forms, with or without
7+
* modification, are permitted provided that the following conditions are met:
8+
*
9+
* 1. Redistributions of source code must retain the above copyright notice, this
10+
* list of conditions and the following disclaimer.
11+
*
12+
* 2. Redistributions in binary form must reproduce the above copyright notice,
13+
* this list of conditions and the following disclaimer in the documentation
14+
* and/or other materials provided with the distribution.
15+
*
16+
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
17+
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18+
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
19+
* DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
20+
* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
21+
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
22+
* SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
23+
* CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
24+
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
25+
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26+
*/
27+
package engineering.swat.watch;
28+
29+
/**
30+
* A visit like interface that allows you to only override the functions you are interested in
31+
*/
32+
public interface WatchEventListener {
33+
default void onCreated(WatchEvent ev) { }
34+
default void onModified(WatchEvent ev) { }
35+
default void onDeleted(WatchEvent ev) { }
36+
default void onOverflow(WatchEvent ev) { }
37+
}

src/main/java/engineering/swat/watch/Watcher.java

Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -100,10 +100,41 @@ public static Watcher watch(Path path, WatchScope scope) {
100100
* @return this for optional method chaining
101101
*/
102102
public Watcher on(Consumer<WatchEvent> eventHandler) {
103+
if (this.eventHandler != NULL_HANDLER) {
104+
throw new IllegalArgumentException("on handler cannot be set more than once");
105+
}
103106
this.eventHandler = eventHandler;
104107
return this;
105108
}
106109

110+
/**
111+
* Convenience variant of {@link #on(Consumer)}, which allows you to only respond to certain events
112+
*/
113+
public Watcher on(WatchEventListener listener) {
114+
if (this.eventHandler != NULL_HANDLER) {
115+
throw new IllegalArgumentException("on handler cannot be set more than once");
116+
}
117+
this.eventHandler = ev -> {
118+
switch (ev.getKind()) {
119+
case CREATED:
120+
listener.onCreated(ev);
121+
break;
122+
case DELETED:
123+
listener.onDeleted(ev);
124+
break;
125+
case MODIFIED:
126+
listener.onModified(ev);
127+
break;
128+
case OVERFLOW:
129+
listener.onOverflow(ev);
130+
break;
131+
default:
132+
throw new IllegalArgumentException("Unexpected kind: " + ev.getKind());
133+
}
134+
};
135+
return this;
136+
}
137+
107138
/**
108139
* Optionally configure the executor in which the {@link #on(Consumer)} callbacks are scheduled.
109140
* If not defined, every task will be scheduled on the {@link java.util.concurrent.ForkJoinPool#commonPool()}.

0 commit comments

Comments
 (0)