12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
# File 'lib/endpoint_flux/endpoint.rb', line 12
def perform(request)
attrs = [request, EndpointFlux::Response.new]
attrs = EndpointFlux.config.interceptor.run(attrs)
request.endpoint = to_s
flow.inject(attrs) do |res, middleware_name|
fetch_middleware(middleware_name).inject(res) do |middleware_res, middleware|
middleware.run(middleware_res)
end
end
rescue *EndpointFlux.config.rescue_from.exceptions => e
EndpointFlux.config.rescue_from.run(name, attrs, e)
end
|