2 async prepared statement
4 <?php include "_skipif.inc"; ?>
11 function complete($s) {
13 while ($s->connection->busy) {
14 $r = array($s->connection->socket);
16 if (stream_select($r, $w, $e, null)) {
17 $s->connection->poll();
20 } while ($s->connection->getResult());
23 $c = new pq\Connection(PQ_DSN);
24 $t = new pq\Types($c);
25 $s = $c->prepareAsync("test", "SELECT \$1,\$2::int4", array($t["int4"]->oid));
29 $s->execAsync(array(1,2), function ($res) {
39 object(pq\Result)#%d (9) {
58 ["statement_position"]=>
60 ["internal_position"]=>