fixed: switched queue implementation details

Signed-off-by: Matt Peterson <[email protected]>
hashgraph · Jun 27, 2024 · 1e3386e · 1e3386e
1 parent 6ff6a8d
commit 1e3386e
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/server/src/main/java/com/hedera/block/server/persistence/WriteThroughCacheHandler.java b/server/src/main/java/com/hedera/block/server/persistence/WriteThroughCacheHandler.java
@@ -20,6 +20,7 @@
 import com.hedera.block.server.persistence.storage.BlockStorage;
 
 import java.util.ArrayDeque;
+import java.util.LinkedList;
 import java.util.Optional;
 import java.util.Queue;
 
@@ -63,13 +64,13 @@ public Long persist(final BlockStreamServiceGrpcProto.Block block) {
      */
     @Override
     public Queue<BlockStreamServiceGrpcProto.Block> readRange(final long startBlockId, final long endBlockId) {
-        final Queue<BlockStreamServiceGrpcProto.Block> blocks = new ArrayDeque<>();
+        final Queue<BlockStreamServiceGrpcProto.Block> blocks = new LinkedList<>();
 
         long count = startBlockId;
         Optional<BlockStreamServiceGrpcProto.Block> blockOpt = read(count);
         while (count <= endBlockId && blockOpt.isPresent()) {
             final BlockStreamServiceGrpcProto.Block block = blockOpt.get();
-            blocks.offer(block);
+            blocks.add(block);
             blockOpt = read(++count);
         }