watcher: Expose isClosed method

Signed-off-by: Giri Ramasamy <46867712+giri-vsr@users.noreply.github.com>
etcd-io · May 13, 2024 · 0906498 · 0906498
1 parent cdd5cd9
commit 0906498
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/jetcd-core/src/main/java/io/etcd/jetcd/Watch.java b/jetcd-core/src/main/java/io/etcd/jetcd/Watch.java
@@ -226,6 +226,11 @@ interface Watcher extends Closeable {
         @Override
         void close();
 
+        /**
+         * Returns if watcher is already closed
+         */
+        boolean isClosed();
+
         /**
          * Requests the latest revision processed and propagates it to listeners
          */

diff --git a/jetcd-core/src/main/java/io/etcd/jetcd/impl/WatchImpl.java b/jetcd-core/src/main/java/io/etcd/jetcd/impl/WatchImpl.java
@@ -143,7 +143,8 @@ final class WatcherImpl implements Watcher {
         //
         // ************************
 
-        boolean isClosed() {
+        @Override
+        public boolean isClosed() {
             return this.closed.get() || WatchImpl.this.closed.get();
         }