Sha256: 0bfbabb395f208ebe9c9e519b42bb16c1a204fcf87d55d53f189fd36c2cec461
Contents?: true
Size: 317 Bytes
Versions: 26
Compression:
Stored size: 317 Bytes
Contents
module Pacer::Pipes
class LabelCollectionFilterPipe < RubyPipe
def initialize(labels)
super()
@labels = Set[*labels.map(&:to_s)]
end
def processNextStart
while true
edge = @starts.next
return edge if edge and @labels.include? edge.getLabel
end
end
end
end
Version data entries
26 entries across 26 versions & 1 rubygems