Module: Plumbing::Pipeline

Defined in:
lib/plumbing/pipeline.rb,
lib/plumbing/pipeline/contracts.rb,
lib/plumbing/pipeline/operations.rb

Overview

A chain of operations that are executed in sequence

Defined Under Namespace

Modules: Contracts, Operations

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.included(base) ⇒ Object 



7
8
9
10
 
# File 'lib/plumbing/pipeline.rb', line 7

def self.included base
  base.extend Plumbing::Pipeline::Contracts
  base.extend Plumbing::Pipeline::Operations
end

Instance Method Details

#call(input) ⇒ Object

Start the pipeline operation with the given input

Parameters:

  • input (Object) —

    the input data to be processed

Returns:

  • (Object) —

    the output data



15
16
17
 
# File 'lib/plumbing/pipeline.rb', line 15

def call input
  self.class._call input, self
end