guzzle3-streams.php

<?php
// an attempt to read data from a local nginx pushstream setup
$this->client = new Client('http://vm.local');
$request = $this->client->get(
    '/sub/foo',
    ['Accept' => '*/*'],
    ['stream' => true],
);

$factory = new PhpStreamRequestFactory();
$stream = $factory->fromRequest($request);

$line = '';

while (!$stream->feof()) {

    $line .= $stream->readLine(10); // hack

    while (false !== strstr($line, $this->delimiter)) {
        list($message, $line) = explode($this->delimiter, $line, 2);
        $message = json_decode($message, true);

        var_dump($message);
    }

}