Optimize memory consumption of Amp\ByteStream\pipe

amphp · Oct 11, 2017 · 5f0665f · 5f0665f
1 parent d60ba03
commit 5f0665f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/lib/functions.php b/lib/functions.php
@@ -24,7 +24,9 @@ function pipe(InputStream $source, OutputStream $destination): Promise {
 
         while (($chunk = yield $source->read()) !== null) {
             $written += \strlen($chunk);
-            yield $destination->write($chunk);
+            $writePromise = $destination->write($chunk);
+            $chunk = null; // free memory
+            yield $writePromise;
         }
 
         return $written;