Add Decompressor#input_stream

rubyzip · Jan 8, 2020 · 6f90c6e · 6f90c6e
1 parent 6cc6717
commit 6f90c6e
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/lib/zip/decompressor.rb b/lib/zip/decompressor.rb
@@ -14,6 +14,7 @@ def self.find_by_compression_method(compression_method)
       decompressor_classes[compression_method]
     end
 
+    attr_reader :input_stream
     attr_reader :decompressed_size
 
     def initialize(input_stream, decompressed_size = nil)

diff --git a/lib/zip/inflater.rb b/lib/zip/inflater.rb
@@ -34,7 +34,7 @@ def zlib_inflater
     def produce_input
       retried = 0
       begin
-        zlib_inflater.inflate(@input_stream.read(Decompressor::CHUNK_SIZE))
+        zlib_inflater.inflate(input_stream.read(Decompressor::CHUNK_SIZE))
       rescue Zlib::BufError
         raise if retried >= 5 # how many times should we retry?
         retried += 1

diff --git a/lib/zip/pass_thru_decompressor.rb b/lib/zip/pass_thru_decompressor.rb
@@ -13,7 +13,7 @@ def read(length = nil, outbuf = '')
       end
 
       @read_so_far += length
-      @input_stream.read(length, outbuf)
+      input_stream.read(length, outbuf)
     end
 
     def eof