4 <?php include "_skipif.inc"; ?>
11 $c = new pq\Connection(PQ_DSN);
12 $c->unbuffered = true;
13 $c->execAsync("SELECT a FROM generate_series(1,3) a", function ($res) {
18 $r = array($c->socket);
20 if (stream_select($r, $w, $e, null)) {
24 } while ($c->getResult());
30 object(pq\Result)#%d (7) {
34 string(12) "SINGLE_TUPLE"
46 object(pq\Result)#%d (7) {
50 string(12) "SINGLE_TUPLE"
62 object(pq\Result)#%d (7) {
66 string(12) "SINGLE_TUPLE"
78 object(pq\Result)#%d (7) {