diff --git a/src/Http/EventStream.php b/src/Http/EventStream.php
index 04ac268..dfde190 100644
--- a/src/Http/EventStream.php
+++ b/src/Http/EventStream.php
@@ -30,14 +30,13 @@ public function __construct(protected Writable $connection, ?ResponseInterface $
         }
     }
 
-    public function write(string $data): self
+    public function write(string $data): bool
     {
-        $this->connection->write($data);
-        return $this;
+        return $this->connection->write($data);
     }
 
-    public function end(): void
+    public function end(): ?bool
     {
-        $this->connection->end();
+        return $this->connection->end();
     }
 }