Class: ActiveSupport::Notifications::Fanout::Subscribers::Timed

Inherits:

Evented

• Object
• Evented
• ActiveSupport::Notifications::Fanout::Subscribers::Timed

Defined in:

lib/skylight/vendor/active_support/notifications/fanout.rb

Instance Method Summary

• #finish(name, id, payload) ⇒ Object
• #initialize(pattern, delegate) ⇒ Timed constructor

  A new instance of Timed.

• #publish(name, *args) ⇒ Object
• #start(name, id, payload) ⇒ Object

Methods inherited from Evented

#matches?, #subscribed_to?

Constructor Details

#initialize(pattern, delegate) ⇒ Timed

Returns a new instance of Timed.

# File 'lib/skylight/vendor/active_support/notifications/fanout.rb', line 114

def initialize(pattern, delegate)
  @timestack = []
  super
end

Instance Method Details

#finish(name, id, payload) ⇒ Object

# File 'lib/skylight/vendor/active_support/notifications/fanout.rb', line 127

def finish(name, id, payload)
  started = @timestack.pop
  @delegate.call(name, started, Time.now, id, payload)
end

#publish(name, *args) ⇒ Object

# File 'lib/skylight/vendor/active_support/notifications/fanout.rb', line 119

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

#start(name, id, payload) ⇒ Object

# File 'lib/skylight/vendor/active_support/notifications/fanout.rb', line 123

def start(name, id, payload)
  @timestack.push Time.now
end