4 <?php include "_skipif.inc"; ?>
10 function complete($c) {
13 $r = array($c->socket);
15 if (stream_select($r, $w, $e, null)) {
19 } while ($c->getResult());
22 $c = new pq\Connection(PQ_DSN);
23 $p = $c->declareAsync("mycursor", pq\Cursor::WITH_HOLD,
24 "SELECT * FROM generate_series(0,29) s WHERE (s%2)=0");
28 $p->fetchAsync(2, function ($r) {
29 foreach ($r as $row) {
30 foreach ($row as $col) {
36 complete($p->connection);
37 $p->moveAsync(1, function ($r) use(&$keep_going) {
38 $keep_going = $r->affectedRows;
40 complete($p->connection);
41 } while ($keep_going);