watcher: Register Exception Handler before watch request

Signed-off-by: Giri Ramasamy <46867712+giri-vsr@users.noreply.github.com>
etcd-io · Dec 14, 2023 · 03546b5 · 03546b5
1 parent e3c0a46
commit 03546b5
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml
@@ -14,7 +14,7 @@ commonsIo = "2.15.1"
 commonCompress = "1.25.0"
 autoService = "1.1.1"
 errorprone = "2.23.0"
-vertx = "4.5.0"
+vertx = "4.5.1"
 picocli = "4.7.5"
 restAssured = "5.3.2"
 

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
@@ -178,13 +178,12 @@ void resume() {
                     builder.addFilters(WatchCreateRequest.FilterType.NOPUT);
                 }
 
-                rstream = Util.applyRequireLeader(option.withRequireLeader(), stub).watch(stream -> {
+                rstream = Util.applyRequireLeader(option.withRequireLeader(), stub).watchWithExceptionHandler(stream -> {
                     wstream.set(stream);
                     stream.write(WatchRequest.newBuilder().setCreateRequest(builder).build());
-                });
+                }, this::onError);
 
                 rstream.handler(this::onNext);
-                rstream.exceptionHandler(this::onError);
                 rstream.endHandler(event -> onCompleted());
             }
         }