Add grabUnique param to WorkerFactory

bzikarsky · Jan 28, 2019 · db54b79 · db54b79
1 parent 37407c4
commit db54b79
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/Factory.php b/src/Factory.php
@@ -76,13 +76,13 @@ function ($error) use ($deferred) {
         return $deferred->promise();
     }
 
-    public function createWorker($host, $port)
+    public function createWorker($host, $port, bool $grabUniques = false)
     {
         $deferred = new Deferred();
         $this->connector->create($host, $port)->then(
-            function ($stream) use ($deferred) {
+            function ($stream) use ($deferred, $grabUniques) {
                 $connection = new Connection($stream, $this->commandFactory);
-                $client = new Worker($connection);
+                $client = new Worker($connection, $grabUniques);
 
                 $client->ping()->then(
                     function () use ($deferred, $client) {