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