Sha256: 2d50a01e8f1924842f4e9ba377a65500333ea5a2d74e0b15ef1afd77f568664f
Contents?: true
Size: 1.26 KB
Versions: 11
Compression:
Stored size: 1.26 KB
Contents
package com.xnlogic.pacer.pipes;
import java.util.Iterator;
import java.util.List;
import com.tinkerpop.pipes.Pipe;
public class BlackboxPipeline<S, E> implements Pipe<S, E> {
private Pipe<S, ?> startPipe;
private Pipe<?, E> endPipe;
public BlackboxPipeline(Pipe<S, ?> startPipe, Pipe<?, E> endPipe) {
this.startPipe = startPipe;
this.endPipe = endPipe;
}
public void setStarts(final Iterator<S> pipe) {
this.startPipe.setStarts(pipe);
}
public void setStarts(final Iterable<S> pipe) {
this.setStarts(pipe.iterator());
}
public E next() {
return this.endPipe.next();
}
public boolean hasNext() {
return this.endPipe.hasNext();
}
public void reset() {
this.endPipe.reset();
}
public void enablePath(boolean enable) {
this.endPipe.enablePath(enable);
}
public List<?> getCurrentPath() {
return this.endPipe.getCurrentPath();
}
public Iterator<E> iterator() {
return this.endPipe.iterator();
}
public void remove() {
throw new UnsupportedOperationException();
}
public String toString() {
return "[" + this.startPipe.toString() + "..." + this.endPipe.toString() + "]";
}
}
Version data entries
11 entries across 11 versions & 1 rubygems