68 lines
1.7 KiB
Ruby
68 lines
1.7 KiB
Ruby
require 'abstract_unit'
|
|
|
|
module ActiveSupport
|
|
module Notifications
|
|
class EventedTest < ActiveSupport::TestCase
|
|
class Listener
|
|
attr_reader :events
|
|
|
|
def initialize
|
|
@events = []
|
|
end
|
|
|
|
def start(name, id, payload)
|
|
@events << [:start, name, id, payload]
|
|
end
|
|
|
|
def finish(name, id, payload)
|
|
@events << [:finish, name, id, payload]
|
|
end
|
|
end
|
|
|
|
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
|
|
|
|
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
|
|
|
|
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
|
|
end
|
|
end
|
|
end
|