lib/celluloid/receivers.rb in celluloid-0.16.0.pre vs lib/celluloid/receivers.rb in celluloid-0.16.0.pre2
- old
+ new
@@ -1,13 +1,14 @@
require 'set'
+
require 'timers'
module Celluloid
# Allow methods to directly interact with the actor protocol
class Receivers
def initialize
@receivers = Set.new
- @timers = Timers.new
+ @timers = Timers::Group.new
end
# Receive an asynchronous message
def receive(timeout = nil, &block)
if Celluloid.exclusive?