fix stream

reactphp-x · Nov 14, 2024 · 2828fa3 · 2828fa3
1 parent 4f80c02
commit 2828fa3
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/src/Bandwidth.php b/src/Bandwidth.php
@@ -65,15 +65,15 @@ public function file(string $path, $p = 0, $length = -1)
 
     public function stream($stream)
     {
-        $stream = new \React\Stream\ThroughStream();
-        $stream->on('data', function ($data) use ($stream) {
-            $this->concurrent->concurrent(function() use ($stream, $data){
-                return $this->bucket->removeTokens(1024 * strlen($data))->then(function () use ($stream, $data) {
-                    $stream->write($data);
+        $_stream = new \React\Stream\ThroughStream();
+        $stream->on('data', function ($data) use ($_stream) {
+            $this->concurrent->concurrent(function() use ($_stream, $data){
+                return $this->bucket->removeTokens(1024 * strlen($data))->then(function () use ($_stream, $data) {
+                    $_stream->write($data);
                 });
             });
         });
-        return $stream;
+        return $_stream;
     }
 
     protected function fileStream($file, $stream, $p, $size)