lib/celluloid/proxy/sync.rb in celluloid-0.17.0 vs lib/celluloid/proxy/sync.rb in celluloid-0.17.1

@@ -1,44 +1,40 @@
-module Celluloid
-  module Proxy
-    # A proxy which sends synchronous calls to an actor
-    class Sync < Abstract
-      attr_reader :mailbox
+# A proxy which sends synchronous calls to an actor
+class Celluloid::Proxy::Sync < Celluloid::Proxy::Abstract
+  attr_reader :mailbox
 
-      # Used for reflecting on proxy objects themselves
-      def __class__
-        Proxy::Sync
-      end
+  # Used for reflecting on proxy objects themselves
+  def __class__
+    ::Celluloid::Proxy::Sync
+  end
 
-      def initialize(mailbox, klass)
-        @mailbox = mailbox
-        @klass = klass
-      end
+  def initialize(mailbox, klass)
+    @mailbox = mailbox
+    @klass = klass
+  end
 
-      def inspect
-        "#<Celluloid::Proxy::Sync(#{@klass})>"
-      end
+  def inspect
+    "#<Celluloid::Proxy::Sync(#{@klass})>"
+  end
 
-      def respond_to?(meth, include_private = false)
-        __class__.instance_methods.include?(meth) || method_missing(:respond_to?, meth, include_private)
-      end
+  def respond_to?(meth, include_private = false)
+    __class__.instance_methods.include?(meth) || method_missing(:respond_to?, meth, include_private)
+  end
 
-      def method_missing(meth, *args, &block)
-        unless @mailbox.alive?
-          fail DeadActorError, "attempted to call a dead actor"
-        end
+  def method_missing(meth, *args, &block)
+    unless @mailbox.alive?
+      fail ::Celluloid::DeadActorError, "attempted to call a dead actor"
+    end
 
-        if @mailbox == ::Thread.current[:celluloid_mailbox]
-          args.unshift meth
-          meth = :__send__
-          # actor = Thread.current[:celluloid_actor]
-          # actor = actor.behavior.subject.bare_object
-          # return actor.__send__(*args, &block)
-        end
-
-        call = Call::Sync.new(::Celluloid.mailbox, meth, args, block)
-        @mailbox << call
-        call.value
-      end
+    if @mailbox == ::Thread.current[:celluloid_mailbox]
+      args.unshift meth
+      meth = :__send__
+      # actor = Thread.current[:celluloid_actor]
+      # actor = actor.behavior.subject.bare_object
+      # return actor.__send__(*args, &block)
     end
+
+    call = ::Celluloid::Call::Sync.new(::Celluloid.mailbox, meth, args, block)
+    @mailbox << call
+    call.value
   end
 end