Sha256: 0815842b8ff6773d8742522bab6a86445fb4dbca437db0b64b0a401fc1132c8b
Contents?: true
Size: 1.96 KB
Versions: 70
Compression:
Stored size: 1.96 KB
Contents
module Celluloid
# A proxy object returned from Celluloid::Actor.spawn/spawn_link which
# dispatches calls and casts to normal Ruby objects which are running inside
# of their own threads.
class ActorProxy
attr_reader :mailbox
def initialize(mailbox, klass = "Object")
@mailbox, @klass = mailbox, klass
end
def send(meth, *args, &block)
Actor.call @mailbox, :send, meth, *args, &block
end
def class
Actor.call @mailbox, :send, :class
end
def respond_to?(meth)
Actor.call @mailbox, :respond_to?, meth
end
def methods(include_ancestors = true)
Actor.call @mailbox, :methods, include_ancestors
end
def alive?
@mailbox.alive?
end
def to_s
Actor.call @mailbox, :to_s
end
def inspect
Actor.call @mailbox, :inspect
rescue DeadActorError
"#<Celluloid::Actor(#{@klass}) dead>"
end
# Create a Celluloid::Future which calls a given method
def future(method_name, *args, &block)
Future.new { Actor.call @mailbox, method_name, *args, &block }
end
# Terminate the associated actor
def terminate
raise DeadActorError, "actor already terminated" unless alive?
begin
send :terminate
rescue DeadActorError
# In certain cases this is thrown during termination. This is likely
# a bug in Celluloid's internals, but it shouldn't affect the caller.
# FIXME: track this down and fix it, or at the very least log it
end
# Always return nil until a dependable exit value can be obtained
nil
end
# method_missing black magic to call bang predicate methods asynchronously
def method_missing(meth, *args, &block)
# bang methods are async calls
if meth.to_s.match(/!$/)
unbanged_meth = meth.to_s.sub(/!$/, '')
Actor.async @mailbox, unbanged_meth, *args, &block
return
end
Actor.call @mailbox, meth, *args, &block
end
end
end
Version data entries
70 entries across 70 versions & 2 rubygems