Merge pull request #144 from clue-labs/unhandled-rejections

Update close handler to avoid unhandled promise rejections

src/Io/Factory.php

@@ -91,6 +91,8 @@ public function createClient(string $uri): PromiseInterface
             // either close successful connection or cancel pending connection attempt
             $connecting->then(function (ConnectionInterface $connection) {
                 $connection->close();
+            }, function () {
+                // ignore to avoid reporting unhandled rejection
             });
             assert(\method_exists($connecting, 'cancel'));
             $connecting->cancel();

src/RedisClient.php

@@ -220,6 +220,8 @@ public function close(): void
         if ($this->promise !== null) {
             $this->promise->then(function (StreamingClient $redis) {
                 $redis->close();
+            }, function () {
+                // ignore to avoid reporting unhandled rejection
             });
             if ($this->promise !== null) {
                 assert(\method_exists($this->promise, 'cancel'));

tests/FunctionalTest.php

@@ -161,15 +161,4 @@ public function testClose(): void
 
         $redis->get('willBeRejectedRightAway')->then(null, $this->expectCallableOnce());
     }
-
-    public function testCloseLazy(): void
-    {
-        $redis = new RedisClient($this->uri, null, $this->loop);
-
-        $redis->get('willBeCanceledAnyway')->then(null, $this->expectCallableOnce());
-
-        $redis->close();
-
-        $redis->get('willBeRejectedRightAway')->then(null, $this->expectCallableOnce());
-    }
 }

tests/Io/FactoryStreamingClientTest.php

@@ -57,13 +57,17 @@ public function testCtor(): void
     public function testWillConnectWithDefaultPort(): void
     {
         $this->connector->expects($this->once())->method('connect')->with('redis.example.com:6379')->willReturn(reject(new \RuntimeException()));
-        $this->factory->createClient('redis.example.com');
+        $promise = $this->factory->createClient('redis.example.com');
+
+        $promise->then(null, $this->expectCallableOnce()); // avoid reporting unhandled rejection
     }
 
     public function testWillConnectToLocalhost(): void
     {
         $this->connector->expects($this->once())->method('connect')->with('localhost:1337')->willReturn(reject(new \RuntimeException()));
-        $this->factory->createClient('localhost:1337');
+        $promise = $this->factory->createClient('localhost:1337');
+
+        $promise->then(null, $this->expectCallableOnce()); // avoid reporting unhandled rejection
     }
 
     public function testWillResolveIfConnectorResolves(): void

tests/RedisClientTest.php

@@ -161,7 +161,10 @@ public function testPingAfterPreviousFactoryRejectsUnderlyingClientWillCreateNew
             new Promise(function () { })
         );
 
-        $this->redis->ping();
+        $promise = $this->redis->ping();
+
+        $promise->then(null, $this->expectCallableOnce()); // avoid reporting unhandled rejection
+
         $deferred->reject($error);
 
         $this->redis->ping();
@@ -308,7 +311,10 @@ public function testCloseAfterPingWillEmitCloseWithoutErrorWhenUnderlyingClientC
         $this->redis->on('error', $this->expectCallableNever());
         $this->redis->on('close', $this->expectCallableOnce());
 
-        $this->redis->ping();
+        $promise = $this->redis->ping();
+
+        $promise->then(null, $this->expectCallableOnce()); // avoid reporting unhandled rejection
+
         $this->redis->close();
     }