Fix handling of rewind after reading all input.

Author: ioquatix

lib/protocol/rack/input.rb

@@ -93,14 +93,18 @@ def read_next
 						# https://github.com/socketry/async-http/issues/183
 						if @body.empty?
 							@body.close
-							@body = nil
+							@closed = true
 						end
 
 						return chunk
 					else
-						# So if we are at the end of the stream, we close it automatically:
-						@body.close
-						@body = nil
+						unless @closed
+							# So if we are at the end of the stream, we close it automatically:
+							@body.close
+							@closed = true
+						end
+						
+						return nil
 					end
 				elsif @closed
 					raise IOError, "Stream is not readable, input has been closed!"

test/protocol/rack/input.rb

@@ -49,7 +49,14 @@
 				expect(input.read).to be == sample_data.join
 				expect(input.read).to be == ""
 
-				expect(input.body).to be_nil
+				expect(input).to be(:closed?)
+			end
+			
+			it "can rewind after reading all input" do
+				expect(input.read).to be == sample_data.join
+				input.rewind
+				
+				expect(input.read).to be == sample_data.join
 			end
 
 			it "can read exactly the content length" do
@@ -69,13 +76,20 @@
 				expect(input.read(3)).to be == "row"
 			end
 
+			it "can rewind after reading partial input" do
+				expect(input.read(3)).to be == "The"
+				input.rewind
+				
+				expect(input.read(3)).to be == "The"
+			end
+			
 			it "can read all input" do
 				expect(input.read(15)).to be == sample_data.join[0...15]
 				expect(input.read).to be == sample_data.join[15..-1]
 
 				expect(input.read(1)).to be == nil
 
-				expect(input.body).to be_nil
+				expect(input).to be(:closed?)
 			end
 
 			it "can read partial input with buffer" do