Close can only be called once

WyriHaximus · Jul 6, 2017 · 51630e2 · 51630e2
1 parent 7bf65ba
commit 51630e2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/ReadableStreamHash.php b/src/ReadableStreamHash.php
@@ -31,7 +31,7 @@ public function __construct(ReadableStreamInterface $stream, string $hash, int $
             $this->emit('data', [$data]);
             hash_update($this->context, $data);
         });
-        $this->stream->on('close', function () {
+        $this->stream->once('close', function () {
             $this->emit('close');
             $this->emit('hash', [
                 hash_final($this->context),

diff --git a/src/WritableStreamHash.php b/src/WritableStreamHash.php
@@ -25,7 +25,7 @@ public function __construct(WritableStreamInterface $stream, string $hash, int $
     {
         $this->stream = $stream;
         $this->context = hash_init($hash, $options, $key);
-        $this->stream->on('close', function () {
+        $this->stream->once('close', function () {
             $this->emit('hash', [
                 hash_final($this->context),
             ]);