remove dependency of Pausing on Supervised

Author: pitr-ch

lib/concurrent/actor/behaviour/pausing.rb

@@ -17,13 +17,13 @@ def initialize(core, subsequent)
         def on_envelope(envelope)
           case envelope.message
           when :pause!
-            from_supervisor?(envelope) { pause! }
+            pause!
           when :resume!
-            from_supervisor?(envelope) { resume! }
+            resume!
           when :reset!
-            from_supervisor?(envelope) { reset! }
+            reset!
           when :restart!
-            from_supervisor?(envelope) { restart! }
+            restart!
           else
             if @paused
               @buffer << envelope
@@ -34,14 +34,6 @@ def on_envelope(envelope)
           end
         end
 
-        def from_supervisor?(envelope)
-          if behaviour!(Supervised).supervisor == envelope.sender
-            yield
-          else
-            false
-          end
-        end
-
         def pause!(error = nil)
           @paused = true
           broadcast(error || :paused)

lib/concurrent/actor/behaviour/supervised.rb

@@ -20,6 +20,13 @@ def on_envelope(envelope)
             supervisor
           when :un_supervise
             un_supervise envelope.sender
+          when :pause!, :resume!, :reset!, :restart!
+            # allow only supervisor to control the actor
+            if @supervisor == envelope.sender
+              pass envelope
+            else
+              false
+            end
           else
             pass envelope
           end