PgChannel fetch throws UnsupportedOperationException (#1600)

tsegismont · web-flow · commit 0bd62588b150 · 2026-01-08T10:35:45.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
@@ -327,9 +327,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
`@@ -327,9 +327,9 @@ public ChannelImpl resume() {`
`327`	`327`	`return this;`
`328`	`328`	`}`
`329`	`329`
`330`		`- // Since Vert.x 3.6.0 : todo`
	`330`	`+ @Override`
`331`	`331`	`public ReadStream<String> fetch(long amount) {`
`332`		`- throw new UnsupportedOperationException();`
	`332`	`+ return resume();`
`333`	`333`	`}`
`334`	`334`	`}`
`335`	`335`