Remove listener only on sucessful attempt

Author: valga

src/ProxyConnector.php

@@ -188,9 +188,10 @@ public function connect($uri)
 
             $stream->write("CONNECT " . $host . ":" . $port . " HTTP/1.1\r\nHost: " . $host . ":" . $port . "\r\n" . $auth . "\r\n");
 
-            return $deferred->promise()->always(function () use ($stream, $fn) {
-                // Stop buffering when connection has been established or rejected.
+            return $deferred->promise()->then(function (ConnectionInterface $stream) use ($fn) {
+                // Stop buffering when connection has been established.
                 $stream->removeListener('data', $fn);
+                return new Promise\FulfilledPromise($stream);
             });
         }, function (Exception $e) use ($proxyUri) {
             throw new RuntimeException('Unable to connect to proxy (ECONNREFUSED)', defined('SOCKET_ECONNREFUSED') ? SOCKET_ECONNREFUSED : 111, $e);