1 files changed, 3 insertions, 2 deletions
diff --git a/src/main/java/com/google/devtools/build/lib/query2/ParallelVisitor.java b/src/main/java/com/google/devtools/build/lib/query2/ParallelVisitor.java
index e98a6afb7e..820bdfc6d2 100644
--- a/src/main/java/com/google/devtools/build/lib/query2/ParallelVisitor.java
+++ b/src/main/java/com/google/devtools/build/lib/query2/ParallelVisitor.java
@@ -15,6 +15,7 @@ package com.google.devtools.build.lib.query2;
 
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.Iterables;
+import com.google.common.collect.Streams;
 import com.google.common.util.concurrent.ThreadFactoryBuilder;
 import com.google.devtools.build.lib.concurrent.AbstractQueueVisitor;
 import com.google.devtools.build.lib.concurrent.BlockingStack;
@@ -140,7 +141,7 @@ public abstract class ParallelVisitor<T> {
 
   void visitAndWaitForCompletion(Iterable<SkyKey> keys)
       throws QueryException, InterruptedException {
-    processingQueue.addAll(ImmutableList.copyOf(preprocessInitialVisit(keys)));
+    Streams.stream(preprocessInitialVisit(keys)).forEachOrdered(processingQueue::add);
     executor.visitAndWaitForCompletion();
   }
 
@@ -205,7 +206,7 @@ public abstract class ParallelVisitor<T> {
         executor.execute(new GetAndProcessResultsTask(keysToUseForResultBatch));
       }
 
-      processingQueue.addAll(ImmutableList.copyOf(visit.keysToVisit));
+      Streams.stream(visit.keysToVisit).forEachOrdered(processingQueue::add);
     }
   }