Sha256: bf7d97c4ecf275002c99495b3ebee7b7b606940a80b505d165600f526c58c8c9
Contents?: true
Size: 408 Bytes
Versions: 37
Compression:
Stored size: 408 Bytes
Contents
module Pacer::Pipes
class ProcessPipe < AbstractPipe
field_reader :starts
attr_reader :is_element, :extensions, :back, :block, :graph
def initialize(back, block)
super()
@block = Pacer::Wrappers::WrappingPipeFunction.new back, block
end
def processNextStart
while true
obj = starts.next
block.call(obj)
return obj
end
end
end
end
Version data entries
37 entries across 37 versions & 1 rubygems