diff --git a/java/client/src/main/java/glide/api/commands/StreamBaseCommands.java b/java/client/src/main/java/glide/api/commands/StreamBaseCommands.java index 79a5731c1b..ba46ace865 100644 --- a/java/client/src/main/java/glide/api/commands/StreamBaseCommands.java +++ b/java/client/src/main/java/glide/api/commands/StreamBaseCommands.java @@ -471,10 +471,6 @@ CompletableFuture xgroupCreate( * ); * } * } - * assert client.xdel("mystream", "1-0").get() == 1L; - * client.xreadgroup(Map.of("mystream", "0"), "mygroup", "myconsumer").get(); - * // Returns "mystream": "1-0": null - * assert streamReadResponse.get("mystream").get("1-0") == null; * */ CompletableFuture>> xreadgroup( @@ -511,12 +507,6 @@ CompletableFuture>> xreadgroup( * ); * } * } - * assert client.xdel("mystream", "1-0").get() == 1L; - * // read the first 10 items and acknowledge (ACK) them: - * StreamReadGroupOptions options = StreamReadGroupOptions.builder().count(10L).noack().build(); - * streamReadResponse = client.xreadgroup(Map.of("mystream", "0"), "mygroup", "myconsumer", options).get(); - * // Returns "mystream": "1-0": null - * assert streamReadResponse.get("mystream").get("1-0") == null; * */ CompletableFuture>> xreadgroup(