Skip to content

Commit

Permalink
Update some Stream docs
Browse files Browse the repository at this point in the history
Signed-off-by: Andrew Carbonetto <[email protected]>
  • Loading branch information
acarbonetto committed Jun 26, 2024
1 parent 1001a7a commit 969fb92
Showing 1 changed file with 0 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -471,10 +471,6 @@ CompletableFuture<String> 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;
* </pre>
*/
CompletableFuture<Map<String, Map<String, String[][]>>> xreadgroup(
Expand Down Expand Up @@ -511,12 +507,6 @@ CompletableFuture<Map<String, Map<String, String[][]>>> 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;
* </pre>
*/
CompletableFuture<Map<String, Map<String, String[][]>>> xreadgroup(
Expand Down

0 comments on commit 969fb92

Please sign in to comment.