Class: ActiveSupport::Notifications::Fanout::Subscribers::MonotonicTimed
- Defined in:
- lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/activesupport-7.0.4/lib/active_support/notifications/fanout.rb
Overview
:nodoc:
Instance Attribute Summary
Attributes inherited from Evented
Instance Method Summary collapse
- #finish(name, id, payload) ⇒ Object
- #publish(name, *args) ⇒ Object
- #start(name, id, payload) ⇒ Object
Methods inherited from Evented
#initialize, #publish_event, #subscribed_to?, #unsubscribe!
Constructor Details
This class inherits a constructor from ActiveSupport::Notifications::Fanout::Subscribers::Evented
Instance Method Details
#finish(name, id, payload) ⇒ Object
250 251 252 253 254 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/activesupport-7.0.4/lib/active_support/notifications/fanout.rb', line 250 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 |
#publish(name, *args) ⇒ Object
241 242 243 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/activesupport-7.0.4/lib/active_support/notifications/fanout.rb', line 241 def publish(name, *args) @delegate.call name, *args end |
#start(name, id, payload) ⇒ Object
245 246 247 248 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/activesupport-7.0.4/lib/active_support/notifications/fanout.rb', line 245 def start(name, id, payload) timestack = IsolatedExecutionState[:_timestack_monotonic] ||= [] timestack.push Process.clock_gettime(Process::CLOCK_MONOTONIC) end |