From 7984d09e834a821841d9e9688c0ccbbe17fc1905 Mon Sep 17 00:00:00 2001
From: Konstantin Grachev <me@grachevko.ru>
Date: Mon, 13 Sep 2021 23:48:17 +0300
Subject: [PATCH] Return Failure on try to write to NullStream

---
 src/Stream/NullStream.php | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/Stream/NullStream.php b/src/Stream/NullStream.php
index cf95f04..14011ed 100644
--- a/src/Stream/NullStream.php
+++ b/src/Stream/NullStream.php
@@ -4,10 +4,11 @@ declare(strict_types=1);
 
 namespace Nsq\Stream;
 
+use Amp\Failure;
 use Amp\Promise;
 use Amp\Success;
+use Nsq\Exception\NsqException;
 use Nsq\Stream;
-use function Amp\call;
 
 final class NullStream implements Stream
 {
@@ -24,8 +25,7 @@ final class NullStream implements Stream
      */
     public function write(string $data): Promise
     {
-        return call(static function (): void {
-        });
+        return new Failure(new NsqException('Connection closed.'));
     }
 
     /**