Log frozen read buffer.

Author: samuel-williams-shopify

lib/io/stream/readable.rb

@@ -191,6 +191,11 @@ def read_until(pattern, offset = 0, limit: nil, chomp: true)
 				matched = @read_buffer.byteslice(0, index+(chomp ? 0 : pattern.bytesize))
 				@read_buffer = @read_buffer.byteslice(index+pattern.bytesize, @read_buffer.bytesize)
 
+				if @read_buffer.frozen?
+					Console.warn(self, "Read buffer is frozen, duplicating it!", name: "read_until")
+					@read_buffer = @read_buffer.dup
+				end
+				
 				return matched
 			end
 		end
@@ -213,6 +218,11 @@ def discard_until(pattern, offset = 0, limit: nil)
 				matched = @read_buffer.byteslice(0, index+pattern.bytesize)
 				@read_buffer = @read_buffer.byteslice(index+pattern.bytesize, @read_buffer.bytesize)
 
+				if @read_buffer.frozen?
+					Console.warn(self, "Read buffer is frozen, duplicating it!", name: "discard_until")
+					@read_buffer = @read_buffer.dup
+				end
+
 				return matched
 			end
 		end
@@ -280,6 +290,11 @@ def gets(separator = $/, limit = nil, chomp: false)
 			line = @read_buffer.byteslice(0, index+(chomp ? 0 : separator.bytesize))
 			@read_buffer = @read_buffer.byteslice(index+separator.bytesize, @read_buffer.bytesize)
 
+			if @read_buffer.frozen?
+				Console.warn(self, "Read buffer is frozen, duplicating it!", name: "gets")
+				@read_buffer = @read_buffer.dup
+			end
+
 			return line
 		end
 
@@ -343,6 +358,11 @@ def fill_read_buffer(size = @minimum_read_size)
 			# This effectively ties the input and output stream together.
 			flush
 
+			if @read_buffer.frozen?
+				Console.warn(self, "Read buffer is frozen, duplicating it!", name: "fill_read_buffer")
+				@read_buffer = @read_buffer.dup
+			end
+			
 			if @read_buffer.empty?
 				if sysread(size, @read_buffer)
 					# Console.info(self, name: "read") {@read_buffer.inspect}
@@ -401,7 +421,13 @@ def consume_read_buffer(size = nil, buffer = nil)
 				else
 					result = @read_buffer.byteslice(0, size)
 				end
+				
 				@read_buffer = @read_buffer.byteslice(size, @read_buffer.bytesize)
+
+				if @read_buffer.frozen?
+					Console.warn(self, "Read buffer is frozen, duplicating it!", name: "consume_read_buffer")
+					@read_buffer = @read_buffer.dup
+				end
 			end
 
 			return result