Sha256: 801857adfb32b71f2d480bf1ab916b262af7b07cf841e7409ab76d3f76ea00fd
Contents?: true
Size: 439 Bytes
Versions: 141
Compression:
Stored size: 439 Bytes
Contents
# frozen_string_literal: true
require "rack/body_proxy"
module ActionDispatch
class Executor
def initialize(app, executor)
@app, @executor = app, executor
end
def call(env)
state = @executor.run!
begin
response = @app.call(env)
returned = response << ::Rack::BodyProxy.new(response.pop) { state.complete! }
ensure
state.complete! unless returned
end
end
end
end
Version data entries
141 entries across 133 versions & 10 rubygems