How to write and read at the same time

[xpader]

Could it implement real streaming like one side is writing, and another side is reading?

Example code (async by amphp):

$stream = Stream::create();

async(function() use ($stream) {
    while ($stream->isReadable()) {
        echo "--read--\n";
        echo $stream->read(512)."\n";
        delay(0.1);
    }
});

for ($i=0; $i<100; $i++) {
    $content = str_repeat((string)$i, 10);
    echo "--write--\n";
    $stream->write($content);
    delay(0.1);
}

$stream->close();

Synchronize code:

$stream = Stream::create();

for ($i=0; $i<100; $i++) {
    $content = str_repeat((string)$i, 10);
    $stream->write($content);
    echo $stream->read(512)."\n";

}

$stream->close();

Can not read anything... The problem is when call write, the cursor of stream is also moved, so read can not read anything..

Currently, must be completely written, then rewind before starting to read, it's not stream.

How do I achieve true streaming while writing and reading at the same time? Imagine download a file from http request, http server is writing, and client is reading, all in streaming.

[odan]

As far as I know the (PHP) stream implementation is not designed for concurrent read/write operations because they share a single cursor. You may try a different approach with a producer-consumer pattern.