golden hour

/opt/alt/tests/alt-php71-pecl-zmq_1.1.3-1.84f0720.el9/tests

File/Folder	Size	Actions
001-send.phpt	451 B
002-test-binary.phpt	538 B
003-getpersistentid.phpt	278 B
004-getendpoints.phpt	724 B
005-forceconnectarg.phpt	631 B
006-sockopt.phpt	754 B
007-addremovepoll.phpt	1.56 KB
008-twowaystoconstruct.phpt	388 B
009-ispersistent.phpt	983 B
010-pollsetinvalidargs.phpt	419 B
011-exceptions.phpt	422 B
012-pollsetremoveinvalid.phpt	395 B
013-pollclearandreuse.phpt	673 B
014-setsockoptparam.phpt	343 B
015-callback.phpt	712 B
016-callbackinvalidargs.phpt	623 B
017-callbackonlyonnewsocket.phpt	786 B
018-callbackpersistent.phpt	521 B
020-exceptionincallback.phpt	407 B
021-callbackwarning.phpt	613 B
022-highwatermark.phpt	1013 B
023-failedcallback.phpt	1.34 KB
024-versionconstant.phpt	222 B
025-sendrecvmulti.phpt	666 B
026-sockettype.phpt	522 B
027-getset.phpt	589 B
028-xpub.phpt	874 B
029-xrepxreqdevice.phpt	971 B
030-xrepmanualqueue.phpt	1.33 KB
031-lastendpoint.phpt	506 B
032-contextopt.phpt	515 B
033-disconnect.phpt	716 B
034-unbind.phpt	678 B
035-capture.phpt	1.29 KB
036-device.phpt	2.25 KB
037-device-deprecated.phpt	665 B
038-cert-construct.phpt	488 B
039-cert-equals.phpt	475 B
040-cert-clone.phpt	268 B
041-cert-meta.phpt	727 B
042-cert-save.phpt	823 B
043-cert-load.phpt	664 B
044-auth-construct.phpt	266 B
045-auth-allow-deny.phpt	371 B
046-cert-apply.phpt	307 B
047-auth-configure.phpt	1.25 KB
048-pollsetitems.phpt	1.15 KB
049-events.phpt	1.12 KB
050-sharedcontext.phpt	699 B
051-socketcount.phpt	1.42 KB
052-pthreads.phpt	1.83 KB
053-z85.phpt	1.26 KB
054-curvekeypair.phpt	631 B
055-socks-proxy.phpt	948 B
bug_gh_156.phpt	647 B
bug_gh_165.phpt	421 B
bug_gh_43.phpt	684 B
bug_gh_49.phpt	1.22 KB
bug_gh_50.phpt	1.2 KB
bug_gh_59.phpt	520 B
bug_gh_59_2.phpt	982 B
libzmq2-sockopt.phpt	14.33 KB
libzmq3-sockopt.phpt	8.66 KB
libzmq4-sockopt.phpt	7.8 KB
rose.jpg	1.54 KB
skipif-czmq2.inc	172 B
skipif-libzmq2.inc	154 B
skipif-libzmq3.inc	154 B
skipif-libzmq4.inc	154 B
skipif.inc	82 B
zeromq_test_helper.inc	705 B

Edit: 030-xrepmanualqueue.phpt

--TEST--
Test send / recv with a manually created XREQ and XREP device
--SKIPIF--
<?php 
    require_once(dirname(__FILE__) . '/skipif.inc'); 
    if(!defined('ZMQ::SOCKOPT_RCVLABEL')) die('skip Only for in libzmq 3.3.0');
?>
--FILE--
<?php

$ctx = new ZMQContext();
$req = new ZMQSocket($ctx, ZMQ::SOCKET_REQ);
$xrep = new ZMQSocket($ctx, ZMQ::SOCKET_XREP);
$xreq = new ZMQSocket($ctx, ZMQ::SOCKET_XREQ);
$rep = new ZMQSocket($ctx, ZMQ::SOCKET_REP);
$xrep->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!"
}