class Warc::Stream::Plain
Public Class Methods
new(fh,options={},&block)
click to toggle source
# File lib/warc/stream.rb, line 28 def initialize(fh,options={},&block) @options = DEFAULT_OPTS.merge options @index = 0 fh = case fh when ::File @name = ::File.basename(fh) fh when String @name = fh @naming_proc = block || lambda {|name,index| "#{name}.#{sprintf('%06d',index)}"} next_file_handle end @file_handle=fh @parser = ::Warc::Parser.new end
new(fh,options={},&block)
click to toggle source
Calls superclass method
Warc::Stream::new
# File lib/warc/stream/plain.rb, line 5 def initialize(fh,options={},&block) @ext = '.warc' super(fh,options,&block) end
Public Instance Methods
read_record()
click to toggle source
# File lib/warc/stream/plain.rb, line 10 def read_record begin self.parser.parse(@file_handle) rescue EOFError # No more records return nil end end
write_record(record)
click to toggle source
Calls superclass method
Warc::Stream#write_record
# File lib/warc/stream/plain.rb, line 18 def write_record(record) super record.dump_to(@file_handle) end