class ActionDispatch::Executor

def call(env)
  state = @executor.run!(reset: true)
  begin
    response = @app.call(env)
    returned = response << ::Rack::BodyProxy.new(response.pop) { state.complete! }
  rescue => error
    @executor.error_reporter.report(error, handled: false)
    raise
  ensure
    state.complete! unless returned
  end
end

def initialize(app, executor)
  @app, @executor = app, executor
end