class ActiveSupport::Notifications::Fanout::Subscribers::MonotonicTimed

:nodoc:

def finish(name, id, payload)

def finish(name, id, payload)
  timestack = IsolatedExecutionState[:_timestack_monotonic]
  started = timestack.pop
  @delegate.call(name, started, Process.clock_gettime(Process::CLOCK_MONOTONIC), id, payload)
end

def publish(name, *args)

:nodoc:
def publish(name, *args)
  @delegate.call name, *args
end

def start(name, id, payload)

def start(name, id, payload)
  timestack = IsolatedExecutionState[:_timestack_monotonic] ||= []
  timestack.push Process.clock_gettime(Process::CLOCK_MONOTONIC)
end