Class: Fall::Pipeline

Inherits:
Object
  • Object
show all
Defined in:
lib/fall/pipeline.rb

Instance Method Summary collapse

Constructor Details

#initialize(source = [].lazy) ⇒ Pipeline

Returns a new instance of Pipeline.



3
4
5
6
 
# File 'lib/fall/pipeline.rb', line 3

def initialize(source = [].lazy)
  @source = source
  @currently_building_pipeline = nil
end

Instance Method Details

#add_operation(operation) ⇒ Object 



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

def add_operation(operation)
  operation.add_to_pipeline(self)
end

#add_record_operation(operation) ⇒ Object 



12
13
14
15
 
# File 'lib/fall/pipeline.rb', line 12

def add_record_operation(operation)
  ensure_current_stage_type(RecordOperationPipeline)
  @currently_building_pipeline.add_operation(operation)
end

#add_stream_operation(operation) ⇒ Object 



17
18
19
20
 
# File 'lib/fall/pipeline.rb', line 17

def add_stream_operation(operation)
  ensure_current_stage_type(StreamOperationPipeline)
  @currently_building_pipeline.add_operation(operation)
end

#to_enum ⇒ Object 



22
23
24
 
# File 'lib/fall/pipeline.rb', line 22

def to_enum
  @currently_building_pipeline.to_enum
end