diff --git a/src/Elasticsearch/ConnectionPool/SniffingConnectionPool.php b/src/Elasticsearch/ConnectionPool/SniffingConnectionPool.php index f39ffe545..8e325ceda 100644 --- 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 index a8bac9df0..9e31a00a9 100644 --- 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