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 $s = $c->prepareAsync("test", "SELECT \$1,\$2::int4", array($c->types->byName->int4->oid));
28 $s->execAsync(array(1,2), function ($res) {
38 object(pq\Result)#%d (6) {