diff options
| author |  nharmata <nharmata@google.com> | 2018-04-12 15:31:26 -0700 |
|---|---|---|
| committer |  Copybara-Service <copybara-piper@google.com> | 2018-04-12 15:33:05 -0700 |
| commit | 398e6dab1092740e38a4ff8657a2f8dee9ee7c20 (patch) | |
| tree | 09da67203e0d378c015f785958c5c9f7f7dfe813 /src/main/java/com/google/devtools/build/lib/query2/ParallelVisitor.java | |
| parent | 06cb84dcf9a0decdd8ff74464137ccd48eb9646e (diff) | |
Provide parallel implementations of bounded allrdeps and rdeps.
RELNOTES: None
PiperOrigin-RevId: 192681579
Diffstat (limited to 'src/main/java/com/google/devtools/build/lib/query2/ParallelVisitor.java')
| -rw-r--r-- | src/main/java/com/google/devtools/build/lib/query2/ParallelVisitor.java | 4 |
1 files changed, 1 insertions, 3 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 bd20259da4..3ea72273a8 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,7 +15,6 @@ 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; @@ -153,8 +152,7 @@ public abstract class ParallelVisitor<T, V> { void visitAndWaitForCompletion(Iterable<SkyKey> keys) throws QueryException, InterruptedException { - Streams.stream(getUniqueValues(preprocessInitialVisit(keys))).forEachOrdered( - processingQueue::add); + getUniqueValues(preprocessInitialVisit(keys)).forEach(processingQueue::add); executor.visitAndWaitForCompletion(); } |