Class: Mementus::Pipeline::Pipe

Inherits:

Object

• Object
• Mementus::Pipeline::Pipe

Defined in:

lib/mementus/pipeline/pipe.rb

Overview

Base class for pipes to inherit from.

Direct Known Subclasses

Filter, Transform

Instance Method Summary

• #call(element) ⇒ Object

  Basic passthrough.

• #initialize(graph) ⇒ Pipe constructor

  A new instance of Pipe.

• #process(element) ⇒ Object

  Basic passthrough.

Constructor Details

#initialize(graph) ⇒ Pipe

Returns a new instance of Pipe.

# File 'lib/mementus/pipeline/pipe.rb', line 5

def initialize(graph)
  @graph = graph
end

Instance Method Details

#call(element) ⇒ Object

Basic passthrough.

# File 'lib/mementus/pipeline/pipe.rb', line 18

def call(element)
  Fiber.yield(element)
end

#process(element) ⇒ Object

Basic passthrough.

# File 'lib/mementus/pipeline/pipe.rb', line 13

def process(element)
  element
end