£Á°èZ¨Ä…–K§‚«“ô4“ÒÙ´dîfUÙÃÅ WKbyʦ•êŽ…È®FÒ¿ÊÎóCozá¬S@6{Í:›œêZÌ:Š•_%:¢¾¾~;‘Ã~芩ÊǍí`ÔÑ©ú뙵'5I¿fš×WO%ø9¾«¾DK|€ùÍD”Ýs]nHÕ¶êםӼ㞪éUWŸÈË%DÒÕ¬ï‘]/Åcx ‰ï2ß]ä6G[]S£Ôϯrs{úëóµmÒï#UQxo·õÞCe]"±/aÙ&Eã4ú9Jé_ÞåëdãöKë)AÞ ¯¹ægƒÛowЍø^d™ý½ßB7áyMä9ÜÖUã !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! --TEST-- Test send / recv with a manually created XREQ and XREP device --SKIPIF-- --FILE-- bind('inproc://xrep'); $xreq->bind('inproc://xreq'); $req->connect('inproc://xrep'); $rep->connect('inproc://xreq'); $in = array('hi', 'there'); $req->sendMulti($in); do { $message = $xrep->recv(); $more = $xrep->getSockOpt(ZMQ::SOCKOPT_RCVMORE); if( $xrep->getSockOpt( ZMQ::SOCKOPT_RCVLABEL ) ) { $xreq->send( $message, ZMQ::MODE_SNDLABEL ); } else { $xreq->send( $message, $more ? ZMQ::MODE_SNDMORE : 0 ); } } while( $more ); $out = $rep->recvMulti(); assert($in == $out); $rep->sendMulti(array("oh", "hello!")); do { $message = $xreq->recv(); $more = $xreq->getSockOpt(ZMQ::SOCKOPT_RCVMORE); if( $xreq->getSockOpt( ZMQ::SOCKOPT_RCVLABEL ) ) { $xrep->send( $message, ZMQ::MODE_SNDLABEL ); } else { $xrep->send( $message, $more ? ZMQ::MODE_SNDMORE : 0 ); } } while( $more ); var_dump($req->recvMulti()); --EXPECT-- array(2) { [0]=> string(2) "oh" [1]=> string(6) "hello!" }