1 files changed, 21 insertions, 0 deletions
diff --git a/lib/rainbows/ev_core/cap_input.rb b/lib/rainbows/ev_core/cap_input.rb
new file mode 100644
index 0000000..a2eecab
--- /dev/null
+++ b/lib/rainbows/ev_core/cap_input.rb
@@ -0,0 +1,21 @@
+# -*- encoding: binary -*-
+# :enddoc:
+class Rainbows::EvCore::CapInput
+  def initialize(io, client)
+    @io, @client, @bytes_left = io, client, Rainbows.max_bytes
+  end
+
+  def <<(buf)
+    if (@bytes_left -= buf.size) < 0
+      @io.close
+      @client.err_413("chunked request body too big")
+    end
+    @io << buf
+  end
+
+  def gets; @io.gets; end
+  def each(&block); @io.each(&block); end
+  def size; @io.size; end
+  def rewind; @io.rewind; end
+  def read(*args); @io.read(*args); end
+end