Merge pull request #12 from spiral/fix/pause-state

Fixes problem with queue "is paused" state checking

src/Queue.php

@@ -203,6 +203,20 @@ public function resume(): void
      * {@inheritDoc}
      */
     public function isPaused(): bool
+    {
+        $stat = $this->getPipelineStat();
+
+        return $stat !== null && ! $stat->getReady();
+    }
+
+    private function createRPCConnection(): RPCInterface
+    {
+        $env = Environment::fromGlobals();
+
+        return RPC::create($env->getRPCAddress());
+    }
+
+    public function getPipelineStat(): ?Stat
     {
         try {
             /** @var Stats $stats */
@@ -214,20 +228,10 @@ public function isPaused(): bool
         /** @var Stat $stat */
         foreach ($stats->getStats() as $stat) {
             if ($stat->getPipeline() === $this->name) {
-                return $stat->getActive() !== 0;
+                return $stat;
             }
         }
 
-        return false;
-    }
-
-    /**
-     * @return RPCInterface
-     */
-    private function createRPCConnection(): RPCInterface
-    {
-        $env = Environment::fromGlobals();
-
-        return RPC::create($env->getRPCAddress());
+        return null;
     }
 }