lib/async/http/body/inflate.rb in async-http-0.36.2 vs lib/async/http/body/inflate.rb in async-http-0.36.3

- old
+ new

@@ -29,11 +29,11 @@ def self.for(body, encoding = GZIP) self.new(body, Zlib::Inflate.new(encoding)) end def read - return if @stream.closed? + return if @stream.finished? if chunk = super @input_length += chunk.bytesize # It's possible this triggers the stream to finish. @@ -42,14 +42,12 @@ @output_length += chunk.bytesize else chunk = @stream.finish @output_length += chunk.bytesize - - @stream.close end - if @stream.finished? and chunk.empty? + if chunk.empty? and @stream.finished? return nil end return chunk end \ No newline at end of file