Emit "close" event once when invoking close()

Author: clue

src/StreamingClient.php

@@ -22,6 +22,7 @@ class StreamingClient extends EventEmitter implements Client
     private $serializer;
     private $requests = array();
     private $ending = false;
+    private $closed = false;
 
     public function __construct(Stream $stream, ParserInterface $parser = null, SerializerInterface $serializer = null)
     {
@@ -57,11 +58,10 @@ public function __construct(Stream $stream, ParserInterface $parser = null, Seri
                 }
             }
         });
-        $stream->on('close', function () use ($that) {
-            $that->close();
-            $that->emit('close');
-        });
+
+        $stream->on('close', array($this, 'close'));
         $stream->resume();
+
         $this->stream = $stream;
         $this->parser = $parser;
         $this->serializer = $serializer;
@@ -119,10 +119,17 @@ public function end()
 
     public function close()
     {
+        if ($this->closed) {
+            return;
+        }
+
         $this->ending = true;
+        $this->closed = true;
 
         $this->stream->close();
 
+        $this->emit('close');
+
         // reject all remaining requests in the queue
         while($this->requests) {
             $request = array_shift($this->requests);

tests/StreamingClientTest.php

@@ -125,8 +125,6 @@ public function testClosedClientRejectsAllNewRequests()
 
     public function testEndingNonBusyClosesClient()
     {
-        $this->markTestIncomplete();
-
         $this->assertFalse($this->client->isBusy());
 
         $this->client->on('close', $this->expectCallableOnce());
@@ -135,8 +133,6 @@ public function testEndingNonBusyClosesClient()
 
     public function testEndingBusyClosesClientWhenNotBusyAnymore()
     {
-        $this->markTestIncomplete();
-
         // count how often the "close" method has been called
         $closed = 0;
         $this->client->on('close', function() use (&$closed) {
@@ -150,9 +146,18 @@ public function testEndingBusyClosesClientWhenNotBusyAnymore()
         $this->assertEquals(0, $closed);
 
         $this->client->handleMessage(new BulkReply('PONG'));
+        $promise->then($this->expectCallableOnce('PONG'));
         $this->assertEquals(1, $closed);
     }
 
+    public function testClosingMultipleTimesEmitsOnce()
+    {
+        $this->client->on('close', $this->expectCallableOnce());
+
+        $this->client->close();
+        $this->client->close();
+    }
+
     public function testReceivingUnexpectedMessageThrowsException()
     {
         $this->setExpectedException('UnderflowException');