gistfile1.txt

<?php

class Response implements ReadableStreamInterface
{
    public function __construct(DuplexStreamInterface $stream, $protocol, $version, $code, $reasonPhrase, $headers)
    {
        $this->stream = $stream;
        $this->protocol = $protocol;
        $this->version = $version;
        $this->code = $code;
        $this->reasonPhrase = $reasonPhrase;
        $this->headers = $headers;

        if (isset($this->headers['Content-Encoding']) && $this->headers['Content-Encoding'] == 'gzip') {
            $this->stream = $this->stream->pipe(ZlibFilterStream::createGzipDecompressor());
        }

        $this->stream->on('data', array($this, 'handleData'));
        $this->stream->on('error', array($this, 'handleError'));
        $this->stream->on('end', array($this, 'handleEnd'));
    }
}