Contents

require 'concurrent/actor/context'

module Concurrent
  module Actor
    module Utils

      module AsAdHoc
        def initialize(*args, &initializer)
          @on_message = Type! initializer.call(*args), Proc
        end

        def on_message(message)
          instance_exec message, &@on_message
        end
      end

      # 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
        include AsAdHoc
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
concurrent-ruby-edge-0.7.2	lib/concurrent-ruby-edge/concurrent/actor/utils/ad_hoc.rb
concurrent-ruby-edge-0.7.1	lib/concurrent-ruby-edge/concurrent/actor/utils/ad_hoc.rb
concurrent-ruby-edge-0.7.0	lib/concurrent-ruby-edge/concurrent/actor/utils/ad_hoc.rb