class ArcFurnace::Observer

Public Class Methods

new(source:) click to toggle source
# File lib/arc-furnace/observer.rb, line 9
def initialize(source:)
  @source = source
end

Public Instance Methods

observe(row) click to toggle source

Observes each row in the node's input stream. This node should not modify the row passed.

This method's return value is ignored

# File lib/arc-furnace/observer.rb, line 25
def observe(row)
  raise "Unimplemented"
end
value() click to toggle source
# File lib/arc-furnace/observer.rb, line 13
def value
  value = source.value.deep_dup
  observe(value) if value
  value
end