Review comments

Signed-off-by: Andrew Carbonetto <[email protected]>
valkey-io · Jun 30, 2024 · 24153a0 · 24153a0
1 parent 6074a94
commit 24153a0
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 11 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
@@ -758,11 +758,11 @@ CompletableFuture<Map<String, String[][]>> xclaim(
      * // 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 (String[] entry: results.get(key)) {
-     *          System.out.printf("{%s=%s}%n", entry[0], entry[1]);
-     *      }
+     * for (String key: results.keySet()) {
+     *     System.out.println(key);
+     *     for (String[] entry: results.get(key)) {
+     *         System.out.printf("{%s=%s}%n", entry[0], entry[1]);
+     *     }
      * }
      * </pre>
      */
@@ -791,8 +791,8 @@ CompletableFuture<Map<String, String[][]>> xclaim(
      * 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);
+     * for (String key: results.keySet()) {
+     *     System.out.println(key);
      * }
      * </pre>
      */
@@ -816,8 +816,8 @@ CompletableFuture<String[]> xclaimJustId(
      * // 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);
+     * for (String key: results.keySet()) {
+     *     System.out.println(key);
      * }
      */
     CompletableFuture<String[]> xclaimJustId(

diff --git a/java/client/src/main/java/glide/api/models/BaseTransaction.java b/java/client/src/main/java/glide/api/models/BaseTransaction.java
@@ -3342,7 +3342,7 @@ public T xpending(
      * @param minIdleTime The minimum idle time for the message to be claimed.
      * @param ids An array of entry ids.
      * @return Command Response - A <code>Map</code> of message entries with the format <code>
-     *     {"entryId": ["entry", "data"], ...}</code> that are claimed by the consumer.
+     *      {"entryId": [["entry", "data"], ...], ...}</code> that are claimed by the consumer.
      */
     public T xclaim(
             @NonNull String key,
@@ -3367,7 +3367,7 @@ public T xclaim(
      * @param ids An array of entry ids.
      * @param options Stream claim options {@link StreamClaimOptions}.
      * @return Command Response - A <code>Map</code> of message entries with the format <code>
-     *     {"entryId": ["entry", "data"], ...}</code> that are claimed by the consumer.
+     *      {"entryId": [["entry", "data"], ...], ...}</code> that are claimed by the consumer.
      */
     public T xclaim(
             @NonNull String key,