diff --git a/src/Pool/Dummy.php b/src/Pool/Dummy.php index bd948b8..ab95aac 100644 --- a/src/Pool/Dummy.php +++ b/src/Pool/Dummy.php @@ -4,7 +4,6 @@ use Evenement\EventEmitterTrait; use React\EventLoop\LoopInterface; -use React\Promise\FulfilledPromise; use React\Promise\PromiseInterface; use WyriHaximus\React\ChildProcess\Messenger\Messages\Message; use WyriHaximus\React\ChildProcess\Messenger\Messages\Rpc; @@ -30,7 +29,7 @@ public function __construct(ProcessCollectionInterface $processCollection, LoopI */ public function rpc(Rpc $message) { - return new FulfilledPromise(); + return \React\Promise\resolve(); } /** diff --git a/src/Queue/Overflow.php b/src/Queue/Overflow.php index 893ccfa..82c396c 100644 --- a/src/Queue/Overflow.php +++ b/src/Queue/Overflow.php @@ -2,7 +2,6 @@ namespace WyriHaximus\React\ChildProcess\Pool\Queue; -use React\Promise\FulfilledPromise; use React\Promise\PromiseInterface; use WyriHaximus\React\ChildProcess\Messenger\Messages\Rpc; use WyriHaximus\React\ChildProcess\Pool\QueueInterface; @@ -67,7 +66,7 @@ public function dequeue() protected function requeue() { if ($this->queue->count() === 0) { - return new FulfilledPromise(); + return \React\Promise\resolve(); } return \React\Promise\resolve($this->queue->dequeue())->then(function (Rpc $rpc) {