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