Class: Reru::StreamConsumer

Inherits:

Object

• Object
• Reru::StreamConsumer

Defined in:

lib/reru/stream_consumer.rb

Instance Method Summary

• #initialize(source, &block) ⇒ StreamConsumer constructor

  A new instance of StreamConsumer.

• #update(source, event) ⇒ Object

Constructor Details

#initialize(source, &block) ⇒ StreamConsumer

Returns a new instance of StreamConsumer.

# File 'lib/reru/stream_consumer.rb', line 2

def initialize(source, &block)
  @block = block
  source.add_observer(self)
end

Instance Method Details

#update(source, event) ⇒ Object

# File 'lib/reru/stream_consumer.rb', line 7

def update(source, event)
  return if event.eos?
  @block.call(event.value)
end