Skip to content
This repository
Browse code

Simplified PipesFluentPipeline interface.

  • Loading branch information...
commit 1fea36731e26919cefe509c613fb3c22f5ba1b82 1 parent a2aa669
Marko A. Rodriguez okram authored
2  src/main/java/com/tinkerpop/pipes/branch/CopySplitPipe.java
@@ -26,7 +26,7 @@ public CopySplitPipe(final List<Pipe> pipes) {
26 26 for (final Pipe pipe : pipes) {
27 27 if (pipe instanceof Pipeline) {
28 28 ((Pipeline) pipe).addPipe(0, new CopyExpandablePipe<S>(this));
29   - this.pipes.add((Pipeline)pipe);
  29 + this.pipes.add((Pipeline) pipe);
30 30 } else {
31 31 final Pipeline<S, ?> pipeline = new Pipeline<S, Object>();
32 32 pipeline.addPipe(new CopyExpandablePipe<S>(this));
2  src/main/java/com/tinkerpop/pipes/branch/ExhaustMergePipe.java
@@ -5,8 +5,6 @@
5 5 import com.tinkerpop.pipes.util.MetaPipe;
6 6 import com.tinkerpop.pipes.util.PipeHelper;
7 7
8   -import java.util.Arrays;
9   -import java.util.Iterator;
10 8 import java.util.List;
11 9 import java.util.NoSuchElementException;
12 10
8 src/main/java/com/tinkerpop/pipes/branch/FairMergePipe.java
@@ -34,13 +34,7 @@ public S processNextStart() {
34 34 this.current = (this.current + 1) % this.total;
35 35 return s;
36 36 } else if (counter == this.total) {
37   - boolean quit = true;
38   - for (Pipe pipe : this.pipes) {
39   - if (pipe.hasNext())
40   - quit = false;
41   - }
42   - if (quit)
43   - throw new NoSuchElementException();
  37 + throw new NoSuchElementException();
44 38 } else {
45 39 this.current = (this.current + 1) % this.total;
46 40 }

0 comments on commit 1fea367

Please sign in to comment.
Something went wrong with that request. Please try again.