Renamed Actor#receive to Actor#act to align with Scala.

lib/concurrent/actor.rb

@@ -38,6 +38,10 @@ def self.pool(count, &block)
 
     protected
 
+    def act(*args)
+      raise NotImplementedError.new("#{self.class} does not implement #act")
+    end
+
     class Poolbox
 
       def initialize(queue)
@@ -71,7 +75,7 @@ def on_task # :nodoc:
       message = @queue.pop
       return if message == :stop
       begin
-        result = receive(*message)
+        result = act(*message)
         changed
         notify_observers(Time.now, message, result)
       rescue => ex

spec/concurrent/actor_spec.rb

@@ -11,7 +11,7 @@ def initialize(&block)
           @task = block
           super()
         end
-        def receive(*message) # :nodoc:
+        def act(*message) # :nodoc:
           @task.call(*message) unless @task.nil?
         end
       end
@@ -273,29 +273,29 @@ def update(*args) @notice = args; end
         end
       end
 
-      context '#receive overloading' do
+      context '#act overloading' do
 
         let(:actor) do
           Class.new(actor_clazz) {
             attr_reader :last_message
-            def receive(*message)
+            def act(*message)
               @last_message = message
             end
           }
         end
 
-        it 'ignores the constructor block' do
-          @expected = false
-          channel = actor.new{|*args| @expected = true }
+        it 'raises an exception if #act is not implemented in the subclass' do
+          channel = Class.new(Actor).new
           @thread = Thread.new{ channel.run }
           @thread.join(0.1)
-          channel.post(:foo)
-          @thread.join(0.1)
-          @expected.should be_false
+          expect {
+            channel.post(:foo)
+            @thread.join(0.1)
+          }.to raise_error(NotImplementedError)
           channel.stop
         end
 
-        it 'uses the subclass receive implementation' do
+        it 'uses the subclass #act implementation' do
           channel = actor.new{|*args| @expected = true }
           @thread = Thread.new{ channel.run }
           @thread.join(0.1)
@@ -311,7 +311,7 @@ def receive(*message)
         let(:actor) do
           Class.new(actor_clazz) {
             attr_reader :last_error
-            def receive(*message)
+            def act(*message)
               raise StandardError
             end
             def on_error(*args)