--TEST-- async unbuffered exec --SKIPIF-- --FILE-- unbuffered = true; $c->execAsync("SELECT a FROM generate_series(1,3) a", function ($res) { var_dump($res); }); 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 object(pq\Result)#%d (6) { ["status"]=> int(9) ["errorMessage"]=> string(0) "" ["numRows"]=> int(1) ["numCols"]=> int(1) ["affectedRows"]=> int(0) ["fetchType"]=> int(0) } object(pq\Result)#%d (6) { ["status"]=> int(9) ["errorMessage"]=> string(0) "" ["numRows"]=> int(1) ["numCols"]=> int(1) ["affectedRows"]=> int(0) ["fetchType"]=> int(0) } object(pq\Result)#%d (6) { ["status"]=> int(9) ["errorMessage"]=> string(0) "" ["numRows"]=> int(1) ["numCols"]=> int(1) ["affectedRows"]=> int(0) ["fetchType"]=> int(0) } object(pq\Result)#%d (6) { ["status"]=> int(2) ["errorMessage"]=> string(0) "" ["numRows"]=> int(0) ["numCols"]=> int(1) ["affectedRows"]=> int(3) ["fetchType"]=> int(0) } DONE