Question: What is the right way to send huge content or live stream content? about http HOT 10 CLOSED

Hi @thestanislav, thanks for your question! What you're looking for is piping a source stream into the destination like this:

$source = new Stream($fp, $loop);
$source->pipe($response);

This controls back-pressure internally: It will make sure the $source will be pause()'d when the destination is not fast enough and starts buffering. It will automatically resume() reading from the $source once the buffer is drained.

I hope this helps 👍

Note: The filesystem is inherently blocking, so it's best to avoid any fopen() calls to begin with. But you may get away with this like this.

from http.

You can probably do a $loop->tick() to force it to process the buffer.

from http.

Thanks, seems that works

from http.

But after some time I have got this:
PHP Fatal error: Allowed memory size of 134217728 bytes exhausted (tried to allocate 65393860 bytes) in vendor/react/stream/src/Buffer.php on line 118

from http.

Hi, @clue . Can you help me with more descriptive example?

$http->on('request', function ($request, $response)  use($loop)  {
    $response->writeHead(200, array('Content-Type' => 'video/mp4'));
    $fp = fopen('Path/to/some/real/big/video.mp4', 'r');

    $source = new Stream($fp, $loop);
    $source->pipe($response);

    fclose($fp);
    $response->end();
});

What I am missing?

from http.

The Stream will close the resource for you once it ends, so you should remove this:

-fclose($fp);

from http.

Same thing.
I'm getting zero length response :(

from http.

After some debug I found out that in my example Stream::handleData is never called.

from http.

$loop->run() helped. Not sure this is a right way.

$http->on('request', function ($request, $response)  use($loop)  {
    $response->writeHead(200, array('Content-Type' => 'video/mp4'));
    $fp = fopen('Path/to/some/real/big/video.mp4', 'r');

    $source = new Stream($fp, $loop);
    $source->pipe($response);
    $loop->run();

    fclose($fp);
    $response->end();
});

from http.

Try this:

$http->on('request', function ($request, $response)  use($loop)  {
    $response->writeHead(200, array('Content-Type' => 'video/mp4'));
    $fp = fopen('Path/to/some/real/big/video.mp4', 'r');

    $source = new Stream($fp, $loop);
    $source->pipe($response);
});

When calling $response->end(); the entire response stream is closed. $source->pipe($response); will do that for you once the file has been completely read and piped into the response.

from http.