gistfile1.php

public function getChangedReadStreams()
{
    $read   = array($this->socket);
    $write  = array();
    $except = array();

    return stream_select($read, $write, $except, 5);
}

/**
 * @return bool|string
 */
public function read()
{
    $done = false;

    $response = '';
    while (!$done) {
        $response .= fread($this->socket, 4096);
        if ($this->getChangedReadStreams() == 0) {
            $done = true;
        }
    }

    return $response;
}