Sha256: e23fe2d442c4b4b46212fce58797349ee7bb67257a54e63b27ad196a5a4e72ee
Contents?: true
Size: 823 Bytes
Versions: 20
Compression:
Stored size: 823 Bytes
Contents
module Pacer
module Pipes
class WrappingPipe < RubyPipe
attr_reader :graph, :element_type, :extensions, :wrapper
def initialize(graph, element_type = nil, extensions = [])
super()
@graph = graph
@element_type = element_type
@extensions = extensions || []
@wrapper = Pacer::Wrappers::WrapperSelector.build graph, element_type, @extensions
end
def getSideEffect
starts.getSideEffect
end
def getCurrentPath
starts.getCurrentPath
end
def wrapper=(w)
if extensions.any? and w.respond_to? :add_extensions
@wrapper = w.add_extensions extensions
else
@wrapper = w
end
end
def processNextStart
wrapper.new graph, starts.next
end
end
end
end
Version data entries
20 entries across 20 versions & 1 rubygems