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