Fix AmpRedisClient pipeline + fix Doc

Author: MacFJA

CHANGELOG.md

@@ -6,6 +6,13 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased v2.x]
 
+## [2.0.1]
+
+### Fixed
+
+- (doc) Fix GPS coordinate (should be longitude first)
+- `AmpRedisClient` pipeline not sequential
+
 ## [2.0.0]
 
 ### Added
@@ -124,7 +131,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 First version
 
 [Unreleased v2.x]: https://github.com/MacFJA/php-redisearch/compare/2.0.0...HEAD
-[1.0.0]: https://github.com/MacFJA/php-redisearch/releases/tag/2.0.0
+[2.0.1]: https://github.com/MacFJA/php-redisearch/compare/2.0.0...2.0.1
+[2.0.0]: https://github.com/MacFJA/php-redisearch/releases/tag/2.0.0
 [Unreleased v1.x]: https://github.com/MacFJA/php-redisearch/compare/1.4.0...1.x
 [1.4.0]: https://github.com/MacFJA/php-redisearch/compare/1.3.0...1.4.0
 [1.3.0]: https://github.com/MacFJA/php-redisearch/compare/1.2.0...1.3.0

README.md

@@ -96,7 +96,7 @@ $index->addDocumentFromArray([
     'firstname' => 'Joe',
     'lastname' => 'Doe',
     'age' => 30,
-    'address' => '40.689247,-74.044502'
+    'address' => '-74.044502,40.689247'
 ]);
 ```
 
@@ -130,14 +130,14 @@ $query = $queryBuilder
     ->addString('Doe')
     ->addElement(
         new Negation(
-            new GeoFacet(['address'], 40.589247, -74.044502, 40, GeoFilterOption::UNIT_KILOMETERS)
+            new GeoFacet(['address'], -74.044502, 40.589247, 40, GeoFilterOption::UNIT_KILOMETERS)
         )
     )
     ->addElement(new Optional(new Word('John')))
     ->render();
 
 // The value of $query is:
-// @age:[(17 +inf] Doe -@address:[40.589247 -74.044502 40.000000 km] ~John
+// @age:[(17 +inf] Doe -@address:[-74.044502 40.589247 40.000000 km] ~John
 ```
 
 ### Pipeline

src/Redis/Client/AmpRedisClient.php

@@ -21,7 +21,6 @@
 
 namespace MacFJA\RediSearch\Redis\Client;
 
-use function Amp\Promise\all;
 use function Amp\Promise\wait;
 use Amp\Redis\Redis;
 use function function_exists;
@@ -39,7 +38,7 @@ private function __construct(Redis $redis)
         if (!static::supports($redis)) {
             throw new RuntimeException($this->getMissingMessage('Amp\Redis', false, [
                 Redis::class => ['query'],
-            ], ['\\Amp\\Promise\\wait', '\\Amp\\Promise\\all']));
+            ], ['\\Amp\\Promise\\wait']));
         }
         $this->redis = $redis;
     }
@@ -65,19 +64,21 @@ public static function supports($redis): bool
     {
         return $redis instanceof Redis
             && method_exists($redis, 'query')
-            && function_exists('\\Amp\\Promise\\wait')
-            && function_exists('\\Amp\\Promise\\all');
+            && function_exists('\\Amp\\Promise\\wait');
     }
 
-    protected function doPipeline(Command ...$commands): array
+    public function pipeline(Command ...$commands): array
     {
         false === static::$disableNotice
             && trigger_error('Warning, \\Amp\\Redis\\Redis don\'t use a real Redis Pipeline', E_USER_NOTICE);
 
-        return wait(all(
-            array_map(function (Command $command) {
-                return $this->redis->query($command->getId(), ...array_map('strval', $command->getArguments()));
-            }, $commands)
-        ));
+        return array_map(function (Command $command) {
+            return $this->execute($command);
+        }, $commands);
+    }
+
+    protected function doPipeline(Command ...$commands): array
+    {
+        return [];
     }
 }