lib/zk/event_handler_subscription/actor.rb in zk-1.4.2 vs lib/zk/event_handler_subscription/actor.rb in zk-1.5.0

@@ -14,18 +14,53 @@
     # forever, however each event will "wait its turn" and all callbacks will
     # receive their events in the same order (which is what ZooKeeper
     # guarantees), just perhaps at different times.
     #
     class Actor < Base
-      include Subscription::ActorStyle
+      # @private
+      attr_reader :threaded_callback
 
+      def initialize(parent, path, callback, opts={})
+        super
+        @threaded_callback = ThreadedCallback.new(@callable)
+      end
+
       def async?
         true
       end
 
+      def call(*args)
+        @threaded_callback.call(*args)
+      end
+      
       # calls unsubscribe and shuts down 
       def close
-        unsubscribe
+        unregister
+      end
+
+      def unregister
+        super
+        @threaded_callback.shutdown
+      end
+
+      def reopen_after_fork!
+        logger.debug { "#{self.class}##{__method__}" }
+        super
+        @threaded_callback.reopen_after_fork!
+      end
+
+      def pause_before_fork_in_parent
+        synchronize do
+          logger.debug { "#{self.class}##{__method__}" }
+          @threaded_callback.pause_before_fork_in_parent
+          super
+        end
+      end
+
+      def resume_after_fork_in_parent
+        super
+        logger.debug { "#{self.class}##{__method__}" }
+        @threaded_callback.resume_after_fork_in_parent
       end
     end
   end
 end