Class: Yajl::Deflate::StreamReader

Inherits:

Zlib::Inflate

• Object
• Zlib::Inflate
• Yajl::Deflate::StreamReader

show all

Defined in:

lib/yajl/deflate/stream_reader.rb

Overview

Class Method Summary (collapse)

• + (Object) parse(input, options = {}, buffer_size = nil, &block)

  Helper method for one-off parsing from a deflate-compressed stream.

Instance Method Summary (collapse)

• - (StreamReader) initialize(io, options) constructor

  Wrapper to the initialize method so we can set the initial IO to parse from.

• - (Object) read(len = nil, buffer = nil)

  A helper method to allow use similar to IO#read.

9
10
11
12

# File 'lib/yajl/deflate/stream_reader.rb', line 9

def initialize(io, options)
  @io = io
  super(options)
end

30
31
32
33
34
35
36
37
38
39
40
41

# File 'lib/yajl/deflate/stream_reader.rb', line 30

def self.parse(input, options={}, buffer_size=nil, &block)
  if input.is_a?(String)
    input = StringIO.new(input)
  end

  if options.is_a?(Hash)
    deflate_options = options.delete(:deflate_options)
    Yajl::Parser.new(options).parse(new(input, deflate_options), buffer_size, &block)
  elsif options.is_a?(Fixnum)
    Yajl::Parser.new.parse(new(input, options), buffer_size, &block)
  end
end

15
16
17
18
19
20
21
22
23
24
25

# File 'lib/yajl/deflate/stream_reader.rb', line 15

def read(len=nil, buffer=nil)
  if val = @io.read(len)
    unless buffer.nil?
      buffer.replace(inflate(val))
      return buffer
    end
    inflate(@io.read(len))
  else
    nil
  end
end