lib/rainbows/ev_core/cap_input.rb

   1 # -*- encoding: binary -*-
   2 # :enddoc:
   3 class Rainbows::EvCore::CapInput
   4
   5   def initialize(io, client, max)
   6     @io, @client, @bytes_left = io, client, max
   7   end
   8
   9   def <<(buf)
  10     if (@bytes_left -= buf.size) < 0
  11       @io.close
  12       @client.err_413("chunked request body too big")
  13     end
  14     @io << buf
  15   end
  16
  17   def gets; @io.gets; end
  18   def each; @io.each { |x| yield x }; end
  19   def size; @io.size; end
  20   def rewind; @io.rewind; end
  21   def read(*args); @io.read(*args); end
  22 end