Class: Ductr::ETL::FiberRunner

Inherits:
Runner
  • Object
show all
Defined in:
lib/ductr/etl/fiber_runner.rb

Overview

A runner built with fibers. Compared to KibaRunner, this one allows to define how control are related to each other. These definitions can be found in Runner#pipes method.

Instance Attribute Summary

Attributes inherited from Runner

#destinations, #pipes, #sources, #transforms

Instance Method Summary collapse

Methods inherited from Runner

#initialize

Constructor Details

This class inherits a constructor from Ductr::ETL::Runner

Instance Method Details

#run ⇒ void

This method returns an undefined value.

Initializes fibers and waits for them to finish.



16
17
18
19
 
# File 'lib/ductr/etl/fiber_runner.rb', line 16

def run
  create_fibers!
  @source_fibers.each_value(&:resume)
end