Remote typehints for sniff and parseClusterState

elastic · Jun 14, 2019 · 1de4044 · 1de4044
1 parent fe8c236
commit 1de4044
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/src/Elasticsearch/ConnectionPool/SniffingConnectionPool.php b/src/Elasticsearch/ConnectionPool/SniffingConnectionPool.php
@@ -124,7 +124,7 @@ private function sniffConnection(Connection $connection): bool
         return true;
     }
 
-    private function parseClusterState(string $transportSchema, array $nodeInfo): array
+    private function parseClusterState(string $transportSchema, $nodeInfo): array
     {
         $pattern       = '/([^:]*):([0-9]+)/';
         $schemaAddress = $transportSchema . '_address';

diff --git a/src/Elasticsearch/Connections/Connection.php b/src/Elasticsearch/Connections/Connection.php
@@ -448,7 +448,10 @@ public function ping(): bool
         }
     }
 
-    public function sniff(): array
+    /**
+     * @return array|\GuzzleHttp\Ring\Future\FutureArray
+     */
+    public function sniff()
     {
         $options = [
             'client' => [
@@ -457,9 +460,7 @@ public function sniff(): array
             ]
         ];
 
-        $future = $this->performRequest('GET', '/_nodes/', null, null, $options);
-
-        return $future->wait();
+        return $this->performRequest('GET', '/_nodes/', null, null, $options);
     }
 
     public function isAlive(): bool