Sha256: 8771d279e77900535f9f99fcd937adf6710dd14e5aa2f7927461a6bdf90a9627
Contents?: true
Size: 598 Bytes
Versions: 11
Compression:
Stored size: 598 Bytes
Contents
package com.xnlogic.pacer.pipes;
import com.tinkerpop.blueprints.Edge;
import com.tinkerpop.pipes.AbstractPipe;
import java.util.regex.Pattern;
public class LabelPrefixPipe extends AbstractPipe<Edge, Edge> {
private Pattern pattern;
public LabelPrefixPipe(final String pattern) {
super();
this.pattern = Pattern.compile("^" + pattern);
}
protected Edge processNextStart() {
while (true) {
Edge e = this.starts.next();
if (this.pattern.matcher(e.getLabel()).matches()) {
return e;
}
}
}
}
Version data entries
11 entries across 11 versions & 1 rubygems