class ActionDispatch::Response::Buffer

def abort
end

def close
  @response.commit!
  @closed = true
end

def closed?
  @closed
end

def each(&block)
  @response.sending!
  x = @buf.each(&block)
  @response.sent!
  x
end

def initialize(response, buf)
  @response = response
  @buf      = buf
  @closed   = false
end

def write(string)
  raise IOError, "closed stream" if closed?
  @response.commit!
  @buf.push string
end