lib/zk/event_handler_subscription/actor.rb in zk-1.1.1 vs lib/zk/event_handler_subscription/actor.rb in zk-1.2.0

@@ -14,22 +14,10 @@
     # 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
-      extend Forwardable
-
-      def_delegators :@threaded_callback, :call
-
-      def initialize(*a)
-        super
-        @threaded_callback = ThreadedCallback.new(@callback)
-      end
-
-      def unsubscribe
-        @threaded_callback.shutdown
-        super
-      end
+      include Subscription::ActorStyle
 
       def async?
         true
       end
     end