class Yajl::Deflate::StreamReader
to the IO spec, allowing for two parameters (length, and buffer)
This is a wrapper around Zlib::Inflate, creating a #read method that adheres
def self.parse(input, options={}, buffer_size=nil, &block)
Helper method for one-off parsing from a deflate-compressed stream
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
def initialize(io, options)
def initialize(io, options) @io = io super(options) end
def read(len=nil, buffer=nil)
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