+ only consider groupId and orderIndex in Chunk.equals

Author: q3769

README.md

@@ -114,10 +114,27 @@ in the same group representing the original data unit.
  */
 @Builder
 public record Chunk(@NonNull UUID groupId, int orderIndex, int groupSize, byte @NonNull [] bytes)
-    implements Serializable {
+        implements Serializable {
 
   @Serial
   private static final long serialVersionUID = -1879320933982945956L;
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (o == null || getClass() != o.getClass()) {
+      return false;
+    }
+    Chunk chunk = (Chunk) o;
+    return orderIndex == chunk.orderIndex && Objects.equals(groupId, chunk.groupId);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(groupId, orderIndex);
+  }
 }
 ```
 

pom.xml

@@ -28,7 +28,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>io.github.q3769</groupId>
     <artifactId>chunk4j</artifactId>
-    <version>20250322.0.0</version>
+    <version>20250322.0.2025</version>
     <packaging>jar</packaging>
     <name>chunk4j</name>
     <description>A Java API to chop up larger data blobs into smaller "chunks" of a pre-defined size, and stitch the

src/main/java/chunk4j/Chunk.java

@@ -26,6 +26,7 @@
 
 import java.io.Serial;
 import java.io.Serializable;
+import java.util.Objects;
 import java.util.UUID;
 import lombok.Builder;
 import lombok.NonNull;
@@ -36,17 +37,34 @@
  * than the one where the data was chopped, the group of chunks can be collectively stitched back
  * together to restore the original data unit.
  *
- * @author Qingtian Wang
  * @param groupId The unique identifier for the entire group of chunks representing the original
  *     data unit.
  * @param orderIndex The order index of this chunk within the chunk group.
  * @param groupSize The total number of chunks in the group.
  * @param bytes The byte array representing the data of this chunk.
+ * @author Qingtian Wang
  */
 @Builder
 public record Chunk(@NonNull UUID groupId, int orderIndex, int groupSize, byte @NonNull [] bytes)
     implements Serializable {
 
   @Serial
   private static final long serialVersionUID = -1879320933982945956L;
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (o == null || getClass() != o.getClass()) {
+      return false;
+    }
+    Chunk chunk = (Chunk) o;
+    return orderIndex == chunk.orderIndex && Objects.equals(groupId, chunk.groupId);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(groupId, orderIndex);
+  }
 }

src/test/java/chunk4j/ChunkStitcherTest.java

@@ -48,7 +48,7 @@ class maxGroups {
     @Test
     void lessThanNeeded() throws InterruptedException, ExecutionException {
       int originalDataItems = 1000;
-      int insufficientMaxGroups = 2;
+      int insufficientMaxGroups = 1;
       ChunkStitcher tot =
           new ChunkStitcher.Builder().maxStitchingGroups(insufficientMaxGroups).build();
       List<Chunk> chunksOfAllItems = new ArrayList<>();
@@ -59,7 +59,7 @@ void lessThanNeeded() throws InterruptedException, ExecutionException {
 
       List<Future<Optional<byte[]>>> allStitchedFutures = new ArrayList<>();
       try (ExecutorService executorService =
-          MoreExecutors.newBoundedVirtualThreadPerTaskExecutor(insufficientMaxGroups * 100)) {
+          MoreExecutors.newBoundedVirtualThreadPerTaskExecutor(insufficientMaxGroups * 10)) {
         for (Chunk chunk : chunksOfAllItems) {
           allStitchedFutures.add(executorService.submit(() -> tot.stitch(chunk)));
         }