ext-pq/tests/unbuffered001.phpt

--TEST--
unbuffered result
--SKIPIF--
<?php include "_skipif.inc"; ?>
--FILE--
<?php
echo "Test\n";

include "_setup.inc";

$c = new pq\Connection(PQ_DSN);
var_dump($c->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("a", $val);
		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