class ActiveSupport::ExecutionWrapper

Public Class Methods

error_reporter() click to toggle source

# File lib/active_support/execution_wrapper.rb, line 111
def self.error_reporter
  @error_reporter ||= ActiveSupport::ErrorReporter.new
end

register_hook(hook, outer: false) click to toggle source

hook.complete will be passed the value returned from hook.run, and will only be invoked if run has previously been called. (Mostly, this means it won’t be invoked if an exception occurs in a preceding to_run block; all ordinary to_complete blocks are invoked in that situation.)

# File lib/active_support/execution_wrapper.rb, line 51
def self.register_hook(hook, outer: false)
  if outer
    to_run RunHook.new(hook), prepend: true
    to_complete :after, CompleteHook.new(hook)
  else
    to_run RunHook.new(hook)
    to_complete CompleteHook.new(hook)
  end
end

run!(reset: false) click to toggle source

Run this execution.

Returns an instance, whose complete! method must be invoked after the work has been performed.

Where possible, prefer wrap.

# File lib/active_support/execution_wrapper.rb, line 67
def self.run!(reset: false)
  if reset
    lost_instance = IsolatedExecutionState.delete(active_key)
    lost_instance&.complete!
  else
    return Null if active?
  end

  new.tap do |instance|
    success = nil
    begin
      instance.run!
      success = true
    ensure
      instance.complete! unless success
    end
  end
end

to_complete(*args, &block) click to toggle source

# File lib/active_support/execution_wrapper.rb, line 22
def self.to_complete(*args, &block)
  set_callback(:complete, *args, &block)
end

to_run(*args, &block) click to toggle source

# File lib/active_support/execution_wrapper.rb, line 18
def self.to_run(*args, &block)
  set_callback(:run, *args, &block)
end

wrap() { || ... } click to toggle source

Perform the work in the supplied block as an execution.

# File lib/active_support/execution_wrapper.rb, line 87
def self.wrap
  return yield if active?

  instance = run!
  begin
    yield
  rescue => error
    error_reporter.report(error, handled: false)
    raise
  ensure
    instance.complete!
  end
end

Public Instance Methods

complete!() click to toggle source

Complete this in-flight execution. This method must be called exactly once on the result of any call to run!.

Where possible, prefer wrap.

# File lib/active_support/execution_wrapper.rb, line 136
def complete!
  complete
ensure
  IsolatedExecutionState.delete(self.class.active_key)
end

Private Instance Methods

hook_state() click to toggle source

# File lib/active_support/execution_wrapper.rb, line 147
def hook_state
  @_hook_state ||= {}
end