lib/dcell/actor_proxy.rb in dcell-0.10.0 vs lib/dcell/actor_proxy.rb in dcell-0.12.0.pre

- old
+ new

@@ -1,4 +1,29 @@ module DCell # Proxy object for actors that live on remote nodes class ActorProxy < Celluloid::ActorProxy; end -end \ No newline at end of file + + class ThreadHandleProxy + def kill + raise NotImplementedError, "remote kill not supported" + end + + def join + raise NotImplementedError, "remote join not supported" + end + end + + class SubjectProxy + def class + "[remote]" + end + end + + class Actor + def initialize(mailbox) + @mailbox = mailbox + @thread = ThreadHandleProxy.new + @subject = SubjectProxy.new + end + attr_reader :mailbox, :thread, :subject + end +end