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