Class: Sq::Dbsync::Pipeline::SimpleContext

Inherits:
Object
  • Object
show all
Defined in:
lib/sq/dbsync/pipeline/simple_context.rb

Overview

A computational context that passes a number of tasks through a set of stages in sequence.

Class Method Summary collapse

Class Method Details

.call(tasks, stages, process) ⇒ Object 



7
8
9
10
11
12
13
 
# File 'lib/sq/dbsync/pipeline/simple_context.rb', line 7

def self.call(tasks, stages, process)
  tasks.map do |task|
    stages.inject(task) do |result, stage|
      process.call(stage, result)
    end
  end
end