| | <?php |
| | +require_once __DIR__ . '/StreamReader.php'; |
| | class CompressionStream { |
| | private Closure $pumper; |
 |
| | } |
| | |
| | - public function stream( mixed $handle, int $chunkSize = 8192 ): Generator { |
| | + public function stream( StreamReader $handle, int $chunkSize = 8192 ): Generator { |
| | $done = false; |
| | |
| | - while( !$done && !feof( $handle ) ) { |
| | - $chunk = fread( $handle, $chunkSize ); |
| | - $done = $chunk === false || $chunk === ''; |
| | + while( !$done && !$handle->eof() ) { |
| | + $chunk = $handle->read( $chunkSize ); |
| | + $done = $chunk === ''; |
| | |
| | if( !$done ) { |