An experimental Celluloid::ActorProxy patch.

monkey_patch.rb

module Celluloid
  class ActorProxy
  private

    def def_async(method)
      impl = ->(*a, &b) {Actor.async @mailbox, method, *a, &b}
      ActorProxy.class_eval {define_method("#{method}!", &impl)}
      impl
    end

    def def_sync(method)
      impl = ->(*a, &b) {Actor.call @mailbox, method, *a, &b}
      ActorProxy.class_eval {define_method(method, &impl)}
      impl
    end

    # method_missing black magic to call bang predicate methods asynchronously
    def method_missing(method, *args, &block)
      # bang methods are async calls
      if method.match(/(.*)!$/)
        def_async($1).call(*args, &block)
      else
        def_sync(method).call(*args, &block)
      end
    end

  end
end