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 index e3f449a82..a3e7d5e25 100644 --- 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 fetch(long amount) { - throw new UnsupportedOperationException(); + return resume(); } }