Class ActiveSupport::Notifications::EventedTest < ActiveSupport::TestCase

# File activesupport/test/notifications/evented_notification_test.rb, line 28
def test_evented_listener
  notifier = Fanout.new
  listener = Listener.new
  notifier.subscribe 'hi', listener
  notifier.start  'hi', 1, {}
  notifier.start  'hi', 2, {}
  notifier.finish 'hi', 2, {}
  notifier.finish 'hi', 1, {}

  assert_equal 4, listener.events.length
  assert_equal [
    [:start, 'hi', 1, {}],
    [:start, 'hi', 2, {}],
    [:finish, 'hi', 2, {}],
    [:finish, 'hi', 1, {}],
  ], listener.events
end

# File activesupport/test/notifications/evented_notification_test.rb, line 46
def test_evented_listener_no_events
  notifier = Fanout.new
  listener = Listener.new
  notifier.subscribe 'hi', listener
  notifier.start  'world', 1, {}
  assert_equal 0, listener.events.length
end

# File activesupport/test/notifications/evented_notification_test.rb, line 72
def test_evented_listener_priority
  notifier = Fanout.new
  listener = ListenerWithTimedSupport.new
  notifier.subscribe 'hi', listener

  notifier.start 'hi', 1, {}
  notifier.finish 'hi', 1, {}

  assert_equal [
    [:start, 'hi', 1, {}],
    [:finish, 'hi', 1, {}]
  ], listener.events
end

# File activesupport/test/notifications/evented_notification_test.rb, line 54
def test_listen_to_everything
  notifier = Fanout.new
  listener = Listener.new
  notifier.subscribe nil, listener
  notifier.start  'hello', 1, {}
  notifier.start  'world', 1, {}
  notifier.finish  'world', 1, {}
  notifier.finish  'hello', 1, {}

  assert_equal 4, listener.events.length
  assert_equal [
    [:start,  'hello', 1, {}],
    [:start,  'world', 1, {}],
    [:finish,  'world', 1, {}],
    [:finish,  'hello', 1, {}],
  ], listener.events
end