Use async for notifications

celluloid · Sep 26, 2013 · 97cb7cb · 97cb7cb
1 parent 775814b
commit 97cb7cb
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/lib/celluloid/notifications.rb b/lib/celluloid/notifications.rb
@@ -5,15 +5,15 @@ def self.notifier
     end
 
     def publish(pattern, *args)
-      Celluloid::Notifications.notifier.publish(pattern, *args)
+      Celluloid::Notifications.notifier.async.publish(pattern, *args)
     end
 
     def subscribe(pattern, method)
-      Celluloid::Notifications.notifier.subscribe(Actor.current, pattern, method)
+      Celluloid::Notifications.notifier.async.subscribe(Actor.current, pattern, method)
     end
 
     def unsubscribe(*args)
-      Celluloid::Notifications.notifier.unsubscribe(*args)
+      Celluloid::Notifications.notifier.async.unsubscribe(*args)
     end
 
     class Fanout