class CsvStream

Constants

BUFFER_SIZE

Public Class Methods

fetch(dir) click to toggle source
# File lib/csv_uploader_tool/csv_stream.rb, line 18
def fetch(dir)
  all_files  = Dir[dir+'/*'].select {|x| x =~ /_.*(csv)/ }
  actual_names = []
  all_files.each do |path|
    actual_names  << File.basename(path)
  end
  actual_names
end
new(file) click to toggle source
# File lib/csv_uploader_tool/csv_stream.rb, line 5
def initialize(file)
  @file = file
end
write(stream, dir, filename) click to toggle source
# File lib/csv_uploader_tool/csv_stream.rb, line 10
def write(stream, dir, filename)
  file = CsvMaker.create_file(dir, filename)
  file_stream = CsvStream.new(file)
  file_stream.write stream
  file_stream.close
  file.path
end

Public Instance Methods

close() click to toggle source
# File lib/csv_uploader_tool/csv_stream.rb, line 34
def close
  @file.close unless @file.closed?
end
write(stream) click to toggle source
# File lib/csv_uploader_tool/csv_stream.rb, line 28
def write(stream)
  while(bytes = stream.read(BUFFER_SIZE))
    @file.write bytes
  end
end