--TEST-- unbuffered result --SKIPIF-- --FILE-- unbuffered ? true : false); $c->unbuffered = 1; var_dump($c->unbuffered); $c->execAsync("SELECT a from generate_series(1,10) a", function($res) { switch ($res->status) { case pq\Result::SINGLE_TUPLE: $res->fetchCol($val, "a"); printf("%s\n", $val); break; case pq\Result::TUPLES_OK: printf("-> fetching done\n"); break; default: printf("!! %s\n", $res->errorMessage); break; } }); do { while ($c->busy) { $r = array($c->socket); $w = $e = null; if (stream_select($r, $w, $e, null)) { $c->poll(); } } } while ($c->getResult()); ?> DONE --EXPECTF-- Test bool(false) bool(true) 1 2 3 4 5 6 7 8 9 10 -> fetching done DONE