execute($buffer, $nread)){ $msg = $unpacker->data(); var_dump($msg); $unpacker->reset(); $buffer = substr($buffer, $nread); $nread = 0; if(!empty($buffer)){ continue; } } break; } } ?>