4 <?php include "_skipif.inc"; ?>
11 $c = new pq\Connection(PQ_DSN);
12 $c->nonblocking = true;
13 var_dump($c->nonblocking);
14 $c->execAsync("SELECT '".str_repeat("a", 6e7)."'", function($r) {
18 var_dump($flushed = $c->flush());
20 while (!$flushed || $c->busy) {
21 $r = $c->busy ? [$c->socket] : null;
22 $w = !$flushed ?[$c->socket] : null;
24 if (stream_select($r, $w, $e, null)) {
26 printf("P%d", $c->poll());
29 printf("F%d", $flushed = $c->flush());
34 } while ($c->getResult());