Move AdHoc to utils

Author: pitr-ch

doc/actor/celluloid_benchmark.rb

@@ -48,7 +48,7 @@ def counting(count, ivar)
     b.report(format('%5d %4d %s', ADD_TO*counts_size, adders_size, 'concurrent')) do
       counts = Array.new(counts_size) { [0, Concurrent::IVar.new] }
       adders = Array.new(adders_size) do |i|
-        Concurrent::Actor::AdHoc.spawn("adder#{i}") do
+        Concurrent::Actor::Utils::AdHoc.spawn("adder#{i}") do
           lambda do |(count, ivar)|
             if count < ADD_TO
               adders[(i+1) % adders_size].tell [count+1, ivar]

lib/concurrent/actor.rb

@@ -26,7 +26,7 @@ module Actor
 
     require 'concurrent/actor/default_dead_letter_handler'
     require 'concurrent/actor/root'
-    require 'concurrent/actor/ad_hoc'
+    require 'concurrent/actor/utils'
 
     # @return [Reference, nil] current executing actor if any
     def self.current

lib/concurrent/actor/ad_hoc.rb

@@ -2,6 +2,7 @@ module Concurrent
   module Actor
     module Utils
       require 'concurrent/actor/utils/broadcast'
+      require 'concurrent/actor/utils/ad_hoc'
     end
   end
 end

lib/concurrent/actor/utills.rb renamed to lib/concurrent/actor/utils.rb

@@ -0,0 +1,21 @@
+module Concurrent
+  module Actor
+    module Utils
+      # Allows quick creation of actors with behaviour defined by blocks.
+      # @example ping
+      #   AdHoc.spawn :forward, an_actor do |where|
+      #     # this block has to return proc defining #on_message behaviour
+      #     -> message { where.tell message  }
+      #   end
+      class AdHoc < Context
+        def initialize(*args, &initializer)
+          @on_message = Type! initializer.call(*args), Proc
+        end
+
+        def on_message(message)
+          instance_exec message, &@on_message
+        end
+      end
+    end
+  end
+end