Stream::close can throw Amp\ByteStream\ClosedException

src/Connection.php

@@ -4,6 +4,7 @@ declare(strict_types=1);
 
 namespace Nsq;
 
+use Amp\ByteStream\ClosedException;
 use Amp\Promise;
 use Nsq\Config\ClientConfig;
 use Nsq\Config\ServerConfig;

src/Stream.php

@@ -4,6 +4,7 @@ declare(strict_types=1);
 
 namespace Nsq;
 
+use Amp\ByteStream\ClosedException;
 use Amp\Promise;
 
 interface Stream
@@ -18,5 +19,8 @@ interface Stream
      */
     public function write(string $data): Promise;
 
+    /**
+     * @throws ClosedException
+     */
     public function close(): void;
 }

src/Stream/SocketStream.php

@@ -63,6 +63,9 @@ class SocketStream implements Stream
         return $this->socket->write($data);
     }
 
+    /**
+     * {@inheritDoc}
+     */
     public function close(): void
     {
         $this->socket->close();