Class: Chicago::Flow::ArraySource

Inherits:

PipelineEndpoint

• Object
• PipelineEndpoint
• Chicago::Flow::ArraySource

Defined in:

lib/chicago/flow/array_source.rb

Instance Attribute Summary

Attributes inherited from PipelineEndpoint

#fields

Instance Method Summary

• #each ⇒ Object
• #initialize(array, fields = []) ⇒ ArraySource constructor

  A new instance of ArraySource.

Methods inherited from PipelineEndpoint

#has_defined_fields?

Constructor Details

#initialize(array, fields = []) ⇒ ArraySource

Returns a new instance of ArraySource.

# File 'lib/chicago/flow/array_source.rb', line 4

def initialize(array, fields=[])
  @fields = [fields].flatten
  @array = array
end

Instance Method Details

#each ⇒ Object

# File 'lib/chicago/flow/array_source.rb', line 9

def each
  @array.each {|row| yield row }
end