Class: Reru::EnumerableStream

Inherits:

Stream

• Object
• Stream
• Reru::EnumerableStream

Defined in:

lib/reru/enumerable_stream.rb

Instance Method Summary

• #initialize(enumerable) ⇒ EnumerableStream constructor

  A new instance of EnumerableStream.

• #run ⇒ Object

Methods inherited from Stream

#consume, #dispatch, #emit, #log, #map, #merge, #select, #to_es

Constructor Details

#initialize(enumerable) ⇒ EnumerableStream

Returns a new instance of EnumerableStream.

# File 'lib/reru/enumerable_stream.rb', line 6

def initialize(enumerable)
  @enumerable = enumerable
end

Instance Method Details

#run ⇒ Object

# File 'lib/reru/enumerable_stream.rb', line 10

def run
  @enumerable.each { |value| emit(Reru::Next.new(value)) }
  emit(Reru::EOS)
end