class Rack::Events::EventedBodyProxy

def call(stream)
  @handlers.reverse_each { |handler| handler.on_send request, response }
  super
end

def each
  @handlers.reverse_each { |handler| handler.on_send request, response }
  super
end

def initialize(body, request, response, handlers, &block)
  super(body, &block)
  @request  = request
  @response = response
  @handlers = handlers
end

def respond_to?(method_name, include_all = false)
  case method_name
  when :each, :call
    @body.respond_to?(method_name, include_all)
  else
    super
  end
end