Fixed failing Test for older PHP Versions

Author: SimonFrings

tests/ConnectionManagerTimeoutTest.php

@@ -1,9 +1,8 @@
 <?php
 
 use ConnectionManager\Extra\ConnectionManagerReject;
-
-use ConnectionManager\Extra\ConnectionManagerDelay;
 use ConnectionManager\Extra\ConnectionManagerTimeout;
+use React\Promise\Deferred;
 use React\Promise\Promise;
 
 class ConnectionManagerTimeoutTest extends TestCase
@@ -27,18 +26,38 @@ public function testTimeoutOkay()
         $promise->then($this->expectCallableOnce(), $this->expectCallableNever());
     }
 
-    public function testTimeoutExpire()
+    public function testTimeoutWillRejectPromiseWhenConnectorExceedsTimeLimit()
     {
-        $will = $this->createConnectionManagerMock(true);
-        $wont = new ConnectionManagerDelay($will, 0.2, $this->loop);
+        $connectionPromise = new Promise(function(){});
+        $connector = $this->getMockBuilder('React\Socket\ConnectorInterface')->getMock();
+        $connector->expects($this->once())->method('connect')->willReturn($connectionPromise);
 
-        $cm = new ConnectionManagerTimeout($wont, 0.1, $this->loop);
+        $cm = new ConnectionManagerTimeout($connector, 0.1, $this->loop);
+
+        $promise = $cm->connect('www.google.com:80');
+        $this->assertInstanceOf('React\Promise\PromiseInterface', $promise);
+
+        $this->loop->run();
+        $promise->then($this->expectCallableNever(), $this->expectCallableOnce());
+    }
+
+    public function testTimeoutWillEndConnectiontWhenConnectorResolvesAfterTimeoutFired()
+    {
+        $connectionDeferred = new Deferred();
+        $connector = $this->getMockBuilder('React\Socket\ConnectorInterface')->getMock();
+        $connector->expects($this->once())->method('connect')->willReturn($connectionDeferred->promise());
+
+        $cm = new ConnectionManagerTimeout($connector, 0.1, $this->loop);
 
         $promise = $cm->connect('www.google.com:80');
         $this->assertInstanceOf('React\Promise\PromiseInterface', $promise);
 
         $this->loop->run();
         $promise->then($this->expectCallableNever(), $this->expectCallableOnce());
+
+        $connection = $this->getMockBuilder('React\Socket\ConnectionInterface')->getMock();
+        $connection->expects($this->once())->method('end');
+        $connectionDeferred->resolve($connection);
     }
 
     public function testTimeoutAbort()