Throw new exception carrying $chunk when fwrite returns 0

lib/CannotWriteChunkException.php

@@ -0,0 +1,23 @@
+<?php
+
+namespace Amp\ByteStream;
+
+final class CannotWriteChunkException extends StreamException
+{
+    /**
+     * @var string
+     */
+    private $chunk;
+
+    public function __construct(string $chunk, string $message = "", int $code = 0, \Throwable $previous = null)
+    {
+        parent::__construct($message, $code, $previous);
+
+        $this->chunk = $chunk;
+    }
+
+    public function getChunk(): string
+    {
+        return $this->chunk;
+    }
+}

lib/ResourceOutputStream.php

@@ -92,7 +92,7 @@ final class ResourceOutputStream implements OutputStream
                             if ($error = \error_get_last()) {
                                 $message .= \sprintf("; %s", $error["message"]);
                             }
-                            throw new StreamException($message);
+                            throw new CannotWriteChunkException($data, $message);
                         }
 
                         $writes->unshift([$data, $previous, $deferred]);