assertNoPreviousOutput(); $this->emitHeaders($response); $this->emitStatusLine($response); $range = $this->parseContentRange($response->getHeaderLine('Content-Range')); if (is_array($range) && $range[0] === 'bytes') { $this->emitBodyRange($range, $response, $maxBufferLength); return; } $this->emitBody($response, $maxBufferLength); } /** * Emit the message body. * * @param ResponseInterface $response * @param int $maxBufferLength */ private function emitBody(ResponseInterface $response, $maxBufferLength) { $body = $response->getBody(); if ($body->isSeekable()) { $body->rewind(); } if (! $body->isReadable()) { echo $body; return; } while (! $body->eof()) { echo $body->read($maxBufferLength); } } /** * Emit a range of the message body. * * @param array $range * @param ResponseInterface $response * @param int $maxBufferLength */ private function emitBodyRange(array $range, ResponseInterface $response, $maxBufferLength) { list($unit, $first, $last, $length) = $range; $body = $response->getBody(); $length = $last - $first + 1; if ($body->isSeekable()) { $body->seek($first); $first = 0; } if (! $body->isReadable()) { echo substr($body->getContents(), $first, $length); return; } $remaining = $length; while ($remaining >= $maxBufferLength && ! $body->eof()) { $contents = $body->read($maxBufferLength); $remaining -= strlen($contents); echo $contents; } if ($remaining > 0 && ! $body->eof()) { echo $body->read($remaining); } } /** * Parse content-range header * http://www.w3.org/Protocols/rfc2616/rfc2616-sec14.html#sec14.16 * * @param string $header * @return false|array [unit, first, last, length]; returns false if no * content range or an invalid content range is provided */ private function parseContentRange($header) { if (preg_match('/(?P[\w]+)\s+(?P\d+)-(?P\d+)\/(?P\d+|\*)/', $header, $matches)) { return [ $matches['unit'], (int) $matches['first'], (int) $matches['last'], $matches['length'] === '*' ? '*' : (int) $matches['length'], ]; } return false; } }