Sha256: f75539f03dd5f0e7fb8a2a2f039ac76555f7a04a13d420b2c6bb87bc66b59624
Contents?: true
Size: 408 Bytes
Versions: 31
Compression:
Stored size: 408 Bytes
Contents
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
31 entries across 31 versions & 4 rubygems