Sha256: 16e6e9c5325051a7362e8c68c0cc41988259fba3c9bc10403f3e11eedf7c503b
Contents?: true
Size: 702 Bytes
Versions: 33
Compression:
Stored size: 702 Bytes
Contents
module Pacer::Pipes
class MultiPipe < RubyPipe
import com.tinkerpop.pipes.util.iterators.MultiIterator
import com.tinkerpop.pipes.Pipe
attr_reader :pipes
def initialize(enums)
super()
@pipes = enums.map do |e|
if e.is_a? Pipe
e
else
e.to_iterable
end
end
setStarts MultiIterator.new(*pipes)
end
def +(enum)
MultiPipe.new(pipes + [enum])
end
def -(enum)
MultiPipe.new(pipes - [enum])
end
def getCurrentPath
starts.getCurrentPath
end
def processNextStart
starts.next
end
def inspect
"#<MultiPipe #{ pipes.count } sources>"
end
end
end
Version data entries
33 entries across 33 versions & 1 rubygems