From 92497059406385ea47b2bb7b6dd7340b1cd2900d Mon Sep 17 00:00:00 2001
From: Andrew Carbonetto <andrew.carbonetto@improving.com>
Date: Sun, 30 Jun 2024 12:16:29 -0700
Subject: [PATCH] Add examples

Signed-off-by: Andrew Carbonetto <andrew.carbonetto@improving.com>
---
 .../api/commands/StreamBaseCommands.java      | 40 +++++++++++++++++++
 1 file changed, 40 insertions(+)

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 959ba31fa5..58066619e8 100644
--- a/java/client/src/main/java/glide/api/commands/StreamBaseCommands.java
+++ b/java/client/src/main/java/glide/api/commands/StreamBaseCommands.java
@@ -687,6 +687,16 @@ CompletableFuture<Object[][]> xpending(
      *     {"entryId": ["entry", "data"], ...}</code> that are claimed by the consumer.
      * @example
      *     <pre>
+     * // read messages from streamId for consumer1
+     * var readResult = client.xreadgroup(Map.of("mystream", entryId), "mygroup", "consumer1").get();
+     * // assign unclaimed messages to consumer2
+     * Map<String, String[]> results = client.xclaim("mystream", "mygroup", "consumer2", 0L, new String[] {entryId}).get();
+     *  for (String key: results.keySet()) {
+     *      System.out.println(key);
+     *      for (int i=0; i<results.get(key).length+1; i=i+2) {
+     *          System.out.println("  {" + results.get(key)[i] + ":" + results.get(key)[i+1] + "}");
+     *      }
+     * }
      * </pre>
      */
     CompletableFuture<Map<String, String[]>> xclaim(
@@ -704,6 +714,18 @@ CompletableFuture<Map<String, String[]>> xclaim(
      * @param options Stream claim options {@link StreamClaimOptions}.
      * @return A <code>Map</code> of message entries with the format <code>
      *     {"entryId": ["entry", "data"], ...}</code> that are claimed by the consumer.
+     * @example
+     *     <pre>
+     * // assign (force) unread and unclaimed messages to consumer2
+     * StreamClaimOptions options = StreamClaimOptions.builder().force().build()
+     * Map<String, String[]> results = client.xclaim("mystream", "mygroup", "consumer2", 0L, new String[] {entryId}, options).get();
+     *  for (String key: results.keySet()) {
+     *      System.out.println(key);
+     *      for (int i=0; i<results.get(key).length+1; i=i+2) {
+     *          System.out.println("  {" + results.get(key)[i] + ":" + results.get(key)[i+1] + "}");
+     *      }
+     * }
+     * </pre>
      */
     CompletableFuture<Map<String, String[]>> xclaim(
             String key,
@@ -724,6 +746,16 @@ CompletableFuture<Map<String, String[]>> xclaim(
      * @param minIdleTime The minimum idle time for the message to be claimed.
      * @param ids An array of entry ids.
      * @return An <code>array</code> of message ids claimed by the consumer.
+     * @example
+     *     <pre>
+     * // read messages from streamId for consumer1
+     * var readResult = client.xreadgroup(Map.of("mystream", entryId), "mygroup", "consumer1").get();
+     * // assign unclaimed messages to consumer2
+     * Map<String, String[]> results = client.xclaimJustId("mystream", "mygroup", "consumer2", 0L, new String[] {entryId}).get();
+     *  for (String key: results.keySet()) {
+     *      System.out.println(key);
+     * }
+     * </pre>
      */
     CompletableFuture<String[]> xclaimJustId(
             String key, String group, String consumer, long minIdleTime, String[] ids);
@@ -740,6 +772,14 @@ CompletableFuture<String[]> xclaimJustId(
      * @param ids An array of entry ids.
      * @param options Stream claim options {@link StreamClaimOptions}.
      * @return An <code>array</code> of message ids claimed by the consumer.
+     * @example
+     *     <pre>
+     * // assign (force) unread and unclaimed messages to consumer2
+     * StreamClaimOptions options = StreamClaimOptions.builder().force().build()
+     * Map<String, String[]> results = client.xclaimJustId("mystream", "mygroup", "consumer2", 0L, new String[] {entryId}, options).get();
+     *  for (String key: results.keySet()) {
+     *      System.out.println(key);
+     * }
      */
     CompletableFuture<String[]> xclaimJustId(
             String key,