aboutsummaryrefslogtreecommitdiffstats
path: root/activesupport/test
diff options
context:
space:
mode:
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