Class: Schlepp::Sink

Inherits:
Object
  • Object
show all
Defined in:
lib/schlepp/sink.rb,
lib/schlepp/sink/filter.rb,
lib/schlepp/sink/filter/chunker.rb,
lib/schlepp/sink/filter/compressor.rb,
lib/schlepp/sink/table_object/stream.rb,
lib/schlepp/sink/filter/formatter/csv.rb,
lib/schlepp/sink/table_object/carosel.rb,
lib/schlepp/sink/table_object/factory.rb,
lib/schlepp/sink/table_object/filters.rb,
lib/schlepp/sink/filter/compressor/stream.rb,
lib/schlepp/sink/filter/compressor/writer.rb,
lib/schlepp/sink/table_object/filter/writer.rb,
lib/schlepp/sink/filter/formatter/csv/writer.rb,
lib/schlepp/sink/table_object/writer/factory.rb,
lib/schlepp/sink/table_object/filter/observer.rb

Defined Under Namespace

Modules: Filter Classes: TableObject

Instance Method Summary collapse

Constructor Details

#initialize(model, factory, filters) ⇒ Sink

Returns a new instance of Sink.



5
6
7
8
 
# File 'lib/schlepp/sink.rb', line 5

def initialize(model, factory, filters)
  @model = model
  @carosel = TableObject::Carosel.new(factory, filters)
end

Instance Method Details

#finalize ⇒ Object 



18
19
20
 
# File 'lib/schlepp/sink.rb', line 18

def finalize
  @carosel.finalize
end

#name ⇒ Object 



10
11
12
 
# File 'lib/schlepp/sink.rb', line 10

def name
  @model.name
end

#write(data) ⇒ Object 



14
15
16
 
# File 'lib/schlepp/sink.rb', line 14

def write(data)
  @carosel.write(data)
end