From 969fb921c9025e3d4aa76adbc06e39685c0d1d8f Mon Sep 17 00:00:00 2001 From: Andrew Carbonetto Date: Wed, 26 Jun 2024 15:53:51 -0700 Subject: [PATCH] Update some Stream docs Signed-off-by: Andrew Carbonetto --- .../java/glide/api/commands/StreamBaseCommands.java | 10 ---------- 1 file changed, 10 deletions(-) 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(