Switch list to threadsafe variant

slackhq · Oct 2, 2024 · 9d67e4d · 9d67e4d
1 parent 36d31c4
commit 9d67e4d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/astra/src/main/java/com/slack/astra/blobfs/BlobStore.java b/astra/src/main/java/com/slack/astra/blobfs/BlobStore.java
@@ -4,9 +4,9 @@
 
 import com.slack.astra.chunk.ReadWriteChunk;
 import java.nio.file.Path;
-import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;
+import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.atomic.AtomicBoolean;
 import org.slf4j.Logger;
@@ -166,7 +166,7 @@ public List<String> listFiles(String prefix) {
     ListObjectsV2Publisher asyncPaginatedListResponse =
         s3AsyncClient.listObjectsV2Paginator(listRequest);
 
-    List<String> filesList = new ArrayList<>();
+    List<String> filesList = new CopyOnWriteArrayList<>();
     try {
       asyncPaginatedListResponse
           .subscribe(