diff options
Diffstat (limited to 'activesupport/test')
-rw-r--r-- | activesupport/test/orchestra_test.rb (renamed from activesupport/test/notifications_test.rb) | 60 |
1 files changed, 30 insertions, 30 deletions
diff --git a/activesupport/test/notifications_test.rb b/activesupport/test/orchestra_test.rb index 8f00eff106..683cc36f6a 100644 --- a/activesupport/test/notifications_test.rb +++ b/activesupport/test/orchestra_test.rb @@ -1,59 +1,59 @@ require 'abstract_unit' -class NotificationsEventTest < Test::Unit::TestCase +class OrchestraEventTest < Test::Unit::TestCase def setup - @parent = ActiveSupport::Notifications::Event.new(:parent) + @parent = ActiveSupport::Orchestra::Event.new(:parent) end def test_initialization_with_name_and_parent_and_payload - event = ActiveSupport::Notifications::Event.new(:awesome, @parent, :payload => "notifications") + event = ActiveSupport::Orchestra::Event.new(:awesome, @parent, :payload => "orchestra") assert_equal(:awesome, event.name) assert_equal(@parent, event.parent) - assert_equal({ :payload => "notifications" }, event.payload) + assert_equal({ :payload => "orchestra" }, event.payload) end def test_thread_id_is_set_on_initialization - event = ActiveSupport::Notifications::Event.new(:awesome) + event = ActiveSupport::Orchestra::Event.new(:awesome) assert_equal Thread.current.object_id, event.thread_id end def test_current_time_is_set_on_initialization previous_time = Time.now.utc - event = ActiveSupport::Notifications::Event.new(:awesome) + event = ActiveSupport::Orchestra::Event.new(:awesome) assert_kind_of Time, event.time assert event.time.to_f >= previous_time.to_f end - + def test_duration_is_set_when_event_finishes - event = ActiveSupport::Notifications::Event.new(:awesome) + event = ActiveSupport::Orchestra::Event.new(:awesome) sleep(0.1) event.finish! assert_in_delta 100, event.duration, 30 end end -class NotificationsMainTest < Test::Unit::TestCase +class OrchestraMainTest < Test::Unit::TestCase def setup @listener = [] - ActiveSupport::Notifications.register @listener + ActiveSupport::Orchestra.register @listener end def teardown - ActiveSupport::Notifications.unregister @listener + ActiveSupport::Orchestra.unregister @listener end - def test_notifications_allows_any_action_to_be_instrumented - event = ActiveSupport::Notifications.instrument(:awesome, "notifications") do + def test_orchestra_allows_any_action_to_be_instrumented + event = ActiveSupport::Orchestra.instrument(:awesome, "orchestra") do sleep(0.1) end assert_equal :awesome, event.name - assert_equal "notifications", event.payload + assert_equal "orchestra", event.payload assert_in_delta 100, event.duration, 30 end def test_block_result_is_stored - event = ActiveSupport::Notifications.instrument(:awesome, "notifications") do + event = ActiveSupport::Orchestra.instrument(:awesome, "orchestra") do 1 + 1 end @@ -61,18 +61,18 @@ class NotificationsMainTest < Test::Unit::TestCase end def test_events_are_published_to_a_listener - event = ActiveSupport::Notifications.instrument(:awesome, "notifications") do + event = ActiveSupport::Orchestra.instrument(:awesome, "orchestra") do 1 + 1 end assert_equal 1, @listener.size assert_equal :awesome, @listener.last.name - assert_equal "notifications", @listener.last.payload + assert_equal "orchestra", @listener.last.payload end def test_nested_events_can_be_instrumented - ActiveSupport::Notifications.instrument(:awesome, "notifications") do - ActiveSupport::Notifications.instrument(:wot, "child") do + ActiveSupport::Orchestra.instrument(:awesome, "orchestra") do + ActiveSupport::Orchestra.instrument(:wot, "child") do sleep(0.1) end @@ -86,23 +86,23 @@ class NotificationsMainTest < Test::Unit::TestCase assert_equal 2, @listener.size assert_equal :awesome, @listener.last.name - assert_equal "notifications", @listener.last.payload + assert_equal "orchestra", @listener.last.payload assert_in_delta 100, @listener.first.parent.duration, 30 end def test_event_is_pushed_even_if_block_fails - ActiveSupport::Notifications.instrument(:awesome, "notifications") do + ActiveSupport::Orchestra.instrument(:awesome, "orchestra") do raise "OMG" end rescue RuntimeError assert_equal 1, @listener.size assert_equal :awesome, @listener.last.name - assert_equal "notifications", @listener.last.payload + assert_equal "orchestra", @listener.last.payload end end -class NotificationsListenerTest < Test::Unit::TestCase - class MyListener < ActiveSupport::Notifications::Listener +class OrchestraListenerTest < Test::Unit::TestCase + class MyListener < ActiveSupport::Orchestra::Listener attr_reader :consumed def consume(event) @@ -113,11 +113,11 @@ class NotificationsListenerTest < Test::Unit::TestCase def setup @listener = MyListener.new - ActiveSupport::Notifications.register @listener + ActiveSupport::Orchestra.register @listener end def teardown - ActiveSupport::Notifications.unregister @listener + ActiveSupport::Orchestra.unregister @listener end def test_thread_is_exposed_by_listener @@ -125,7 +125,7 @@ class NotificationsListenerTest < Test::Unit::TestCase end def test_event_is_consumed_when_an_action_is_instrumented - ActiveSupport::Notifications.instrument(:sum) do + ActiveSupport::Orchestra.instrument(:sum) do 1 + 1 end sleep 0.1 @@ -136,10 +136,10 @@ class NotificationsListenerTest < Test::Unit::TestCase def test_with_sevaral_consumers_and_several_events @another = MyListener.new - ActiveSupport::Notifications.register @another + ActiveSupport::Orchestra.register @another 1.upto(100) do |i| - ActiveSupport::Notifications.instrument(:value) do + ActiveSupport::Orchestra.instrument(:value) do i end end @@ -156,6 +156,6 @@ class NotificationsListenerTest < Test::Unit::TestCase assert_equal 1, @another.consumed.first.result assert_equal 100, @another.consumed.last.result ensure - ActiveSupport::Notifications.unregister @another + ActiveSupport::Orchestra.unregister @another end end |