PgChannel fetch throws UnsupportedOperationException (#1602) (#1605)

tsegismont · web-flow · commit 11248dadd888 · 2026-01-08T11:36:31.000+01:00
See #1403 Instead, fetch may call resume Signed-off-by: Thomas Segismont <tsegismont@gmail.com>
diff --git a/vertx-pg-client/src/main/java/io/vertx/pgclient/impl/pubsub/PgSubscriberImpl.java b/vertx-pg-client/src/main/java/io/vertx/pgclient/impl/pubsub/PgSubscriberImpl.java
@@ -321,9 +321,9 @@ public ChannelImpl resume() {
       return this;
     }
 
-    // Since Vert.x 3.6.0 : todo
+    @Override
     public ReadStream<String> fetch(long amount) {
-      throw new UnsupportedOperationException();
+      return resume();
     }
   }
 

Original file line number	Diff line number	Diff line change
`@@ -321,9 +321,9 @@ public ChannelImpl resume() {`
`321`	`321`	`return this;`
`322`	`322`	`}`
`323`	`323`
`324`		`- // Since Vert.x 3.6.0 : todo`
	`324`	`+ @Override`
`325`	`325`	`public ReadStream<String> fetch(long amount) {`
`326`		`- throw new UnsupportedOperationException();`
	`326`	`+ return resume();`
`327`	`327`	`}`
`328`	`328`	`}`
`329`	`329`