Proxy Streaming#empty? to @input.

socketry · Apr 3, 2024 · b438ae9 · b438ae9
1 parent d92266f
commit b438ae9
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/lib/protocol/rack/body/streaming.rb b/lib/protocol/rack/body/streaming.rb
@@ -41,6 +41,14 @@ def read
 					end
 				end
 
+				def empty?
+					if @input
+						@input.empty?
+					else
+						true
+					end
+				end
+
 				# Invokes the block in a fiber which yields chunks when they are available.
 				def read
 					@output ||= Output.new(@input, @block)