Simplify queue draining code

reactphp · Jul 13, 2015 · cc6f1c3 · cc6f1c3
1 parent e855942
commit cc6f1c3
Showing 1 changed file with 3 additions and 17 deletions.
diff --git a/src/Queue/SynchronousQueue.php b/src/Queue/SynchronousQueue.php
@@ -15,23 +15,9 @@ public function enqueue(callable $task)
 
     private function drain()
     {
-        for ($i = key($this->queue); isset($this->queue[$i]); $i++) {
-            $task = $this->queue[$i];
-
-            $exception = null;
-
-            try {
-                $task();
-            } catch (\Exception $exception) {
-            }
-
-            unset($this->queue[$i]);
-
-            if ($exception) {
-                throw $exception;
-            }
+        /** @var callable $task */
+        while ($task = array_shift($this->queue)) {
+            $task();
         }
-
-        $this->queue = [];
     }
 }