Don't stream body wrappers that don't support it.

Author: ioquatix

lib/protocol/http/body/deflate.rb

@@ -89,6 +89,12 @@ def self.for(body, window_size = GZIP, level = DEFAULT_LEVEL)
 					self.new(body, Zlib::Deflate.new(level, window_size))
 				end
 
+				def stream?
+					# We might want to revisit this design choice.
+					# We could wrap the streaming body in a Deflate stream, but that would require an extra stream wrapper which we don't have right now. See also `Digestable#stream?`.
+					false
+				end
+				
 				def read
 					return if @stream.finished?
 

lib/protocol/http/body/digestable.rb

@@ -50,6 +50,10 @@ def etag
 					@digest.hexdigest.dump
 				end
 
+				def stream?
+					false
+				end
+				
 				def read
 					if chunk = super
 						@digest.update(chunk)

lib/protocol/http/body/file.rb

@@ -73,6 +73,10 @@ def rewind
 					@file.seek(@offset)
 				end
 
+				def stream?
+					false
+				end
+				
 				def read
 					if @remaining > 0
 						amount = [@remaining, @block_size].min

lib/protocol/http/body/inflate.rb

@@ -32,6 +32,10 @@ def self.for(body, encoding = GZIP)
 					self.new(body, Zlib::Inflate.new(encoding))
 				end
 
+				def stream?
+					false
+				end
+				
 				def read
 					return if @stream.finished?
 

lib/protocol/http/body/rewindable.rb

@@ -48,6 +48,10 @@ def buffered
 					Buffered.new(@chunks)
 				end
 
+				def stream?
+					false
+				end
+				
 				def read
 					if @index < @chunks.size
 						chunk = @chunks[@index]