Class: Julewire::Rails::RequestCompletion

Inherits:
Object
  • Object
show all
Defined in:
lib/julewire/rails/request_completion.rb

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(configuration:, execution_handle:, instrumenter_handle:, env:, request:, request_error:) ⇒ RequestCompletion

Returns a new instance of RequestCompletion.



26
27
28
29
30
31
32
33
 
# File 'lib/julewire/rails/request_completion.rb', line 26

def initialize(configuration:, execution_handle:, instrumenter_handle:, env:, request:, request_error:)
  @configuration = configuration
  @execution_handle = execution_handle
  @instrumenter_handle = instrumenter_handle
  @env = env
  @request = request
  @request_error = request_error
end

Class Method Details

.finish_instrumentation(instrumenter_handle) ⇒ Object 



9
10
11
12
13
14
15
 
# File 'lib/julewire/rails/request_completion.rb', line 9

def finish_instrumentation(instrumenter_handle)
  instrumenter_handle.finish
rescue StandardError
  nil
ensure
  flush_log_subscribers
end

Instance Method Details

#attach(response) ⇒ Object 



35
36
37
38
39
40
41
42
43
 
# File 'lib/julewire/rails/request_completion.rb', line 35

def attach(response)
  status, headers, body = response
  timeout_token = nil
  finish_once = completion_callback { RequestSummaryTimeoutScheduler.cancel(timeout_token) }
  install_response_finished_callback(finish_once)
  timeout_token = install_completion_timeout
  body = ContextBodyProxy.new(body, handle: @execution_handle, on_close: -> { finish_once.call(nil) })
  response.frozen? ? [status, headers, body] : response.tap { it[2] = body }
end