When reading from an open socket how do you know if you read all the bits and pieces o

tryUnpack - how do you know when to return while streaming about msgpack.php HOT 2 CLOSED

rybakit commented on May 23, 2024

tryUnpack - how do you know when to return while streaming

from msgpack.php.

Comments (2)

rybakit commented on May 23, 2024

A non-empty result of the $unpacker->tryUnpack() call indicates that the entire msgpack message (or several) has been received and unpacked. If you expect only one message from a stream, you can just do:

if ($unpackedBlocks = $unpacker->tryUnpack()) {
    return $unpackedBlocks[0];
}

If you receive an unknown number of msgpack messages from the stream, then I guess feof() is the right way to break the loop.

from msgpack.php.

decebal commented on May 23, 2024

that was so simple, I can't believe I didn't figure that out. I was trying to compare the lengths somehow..
Here's my snippet now:

         stream_set_blocking($io, 0);
         $unpackedBlocks = null;
         $unpacker = new BufferUnpacker();

        while (!feof($io)) {
            $r = array($io);
            $n = null;
            stream_select($r, $n, $n, null);
            $read = fread($io, $size);
            if ($read === false) {
                throw new MessagePackRPCNetworkException(error_get_last());
            }
            $unpacker->append($read);
            $unpackedBlocks = $unpacker->tryUnpack();
            if ($unpackedBlocks) {
                  return $unpackedBlocks;
            }
        }

        throw new RPCNetworkException("Could not read the server response!");

Also this allows me to process multiple messages at once!

from msgpack.php.

Recommend Projects