Skeleton for testing Client

Author: clue

src/Client.php

@@ -5,7 +5,7 @@
 use Clue\React\Ami\Protocol\Event;
 use Clue\React\Ami\Protocol\Action;
 use Evenement\EventEmitter;
-use React\Stream\Stream;
+use React\Stream\StreamInterface;
 use Clue\React\Ami\Protocol\Parser;
 use React\Promise\Deferred;
 use Exception;
@@ -19,7 +19,7 @@ class Client extends EventEmitter
     private $pending = array();
     private $ending = false;
 
-    public function __construct(Stream $stream, Parser $parser = null)
+    public function __construct(StreamInterface $stream, Parser $parser = null)
     {
         if ($parser === null) {
             $parser = new Parser();

tests/ClientTest.php

@@ -0,0 +1,21 @@
+<?php
+
+use React\Stream\Stream;
+use Clue\React\Ami\Protocol\Parser;
+use Clue\React\Ami\Client;
+use React\Stream\ThroughStream;
+
+class ClientTest extends TestCase
+{
+    public function testClosingStreamClosesClient()
+    {
+        $stream = new ThroughStream();
+
+        $client = new Client($stream);
+
+        $client->on('close', $this->expectCallableOnce());
+
+        $stream->close();
+        //$stream->emit('close', array($this));
+    }
+}

tests/bootstrap.php

@@ -4,5 +4,36 @@
 
 class TestCase extends PHPUnit_Framework_TestCase
 {
+    protected function expectCallableOnce()
+    {
+        $mock = $this->createCallableMock();
 
+        if (func_num_args() > 0) {
+            $mock
+                ->expects($this->once())
+                ->method('__invoke')
+                ->with($this->equalTo(func_get_arg(0)));
+        } else {
+            $mock
+                ->expects($this->once())
+                ->method('__invoke');
+        }
+
+        return $mock;
+    }
+
+    /**
+     * @link https://github.com/reactphp/react/blob/master/tests/React/Tests/Socket/TestCase.php (taken from reactphp/react)
+     */
+    protected function createCallableMock()
+    {
+        return $this->getMock('CallableStub');
+    }
+}
+
+class CallableStub
+{
+    public function __invoke()
+    {
+    }
 }