class Mementus::Pipeline::Pipe
Base class for pipes to inherit from.
Attributes
graph[R]
Public Class Methods
new(graph)
click to toggle source
# File lib/mementus/pipeline/pipe.rb, line 5 def initialize(graph) @graph = graph end
Public Instance Methods
call(element)
click to toggle source
Basic passthrough.
# File lib/mementus/pipeline/pipe.rb, line 18 def call(element) Fiber.yield(element) end
process(element)
click to toggle source
Basic passthrough.
# File lib/mementus/pipeline/pipe.rb, line 13 def process(element) element end