class Schlepp::Sink::TableObject::Filter::Writer
Public Class Methods
new(writer, observer, opts = {})
click to toggle source
# File lib/schlepp/sink/table_object/filter/writer.rb, line 6 def initialize(writer, observer, opts = {}) @writer = writer @observer = observer end
Public Instance Methods
finalize()
click to toggle source
# File lib/schlepp/sink/table_object/filter/writer.rb, line 18 def finalize @writer.finalize @observer.reset end
write(rows)
click to toggle source
# File lib/schlepp/sink/table_object/filter/writer.rb, line 11 def write(rows) Array(rows).each do |row| @writer.write(row) @observer.add(row) end end