TINKERPOP-1595 Removed stream() usage
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/344d1b24 Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/344d1b24 Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/344d1b24 Branch: refs/heads/TINKERPOP-1595 Commit: 344d1b24445fb332b88ecce9af8020f91046c3e0 Parents: 172dfa5 Author: Stephen Mallette <[email protected]> Authored: Tue Apr 24 08:00:48 2018 -0400 Committer: Stephen Mallette <[email protected]> Committed: Fri Apr 27 10:32:44 2018 -0400 ---------------------------------------------------------------------- .../process/computer/traversal/TraversalVertexProgram.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/344d1b24/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/TraversalVertexProgram.java ---------------------------------------------------------------------- diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/TraversalVertexProgram.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/TraversalVertexProgram.java index 3cb4d00..40417cc 100644 --- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/TraversalVertexProgram.java +++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/TraversalVertexProgram.java @@ -175,12 +175,11 @@ public final class TraversalVertexProgram implements VertexProgram<TraverserSet< this.traversal.get().getParent().asStep().getNextStep() instanceof EmptyStep || // same as above, but if using TraversalVertexProgramStep directly (this.traversal.get().getParent().asStep().getNextStep() instanceof ProfileStep && // same as above, but needed for profiling this.traversal.get().getParent().asStep().getNextStep().getNextStep() instanceof ComputerResultStep)); + // determine how to store halted traversers - this.haltedTraverserStrategy = ((HaltedTraverserStrategy) this.traversal.get().getStrategies().toList() - .stream() - .filter(strategy -> strategy instanceof HaltedTraverserStrategy) - .findAny() - .orElse(HaltedTraverserStrategy.reference())); + final Iterator<?> itty = IteratorUtils.filter(this.traversal.get().getStrategies().toList(), strategy -> strategy instanceof HaltedTraverserStrategy).iterator(); + this.haltedTraverserStrategy = itty.hasNext() ? (HaltedTraverserStrategy) itty.next() : HaltedTraverserStrategy.reference(); + // register traversal side-effects in memory this.memoryComputeKeys.addAll(MemoryTraversalSideEffects.getMemoryComputeKeys(this.traversal.get())); // register MapReducer memory compute keys
