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