msgpack/php/test_streaming.php at java-0.5.1 · WanderWalker/msgpack · GitHub

Repository navigation

31 lines (24 loc) · 615 Bytes

<?php

// serialized data

$msgs = array(pack("C*", 0x93, 0x01, 0x02, 0x03, 0x92), pack("C*", 0x03, 0x09, 0x04));

// streaming deserialize

$unpacker = new MessagePackUnpacker();

$buffer = "";

$nread = 0;

foreach($msgs as $msg){

$buffer = $buffer . $msg;

while(true){

if($unpacker->execute($buffer, $nread)){

$msg = $unpacker->data();

var_dump($msg);

$unpacker->reset();

$buffer = substr($buffer, $nread);

$nread = 0;

if(!empty($buffer)){

continue;

}

break;

}