X-Git-Url: https://git.m6w6.name/?p=m6w6%2Fext-pq;a=blobdiff_plain;f=tests%2Funbuffered001.phpt;h=b0df231c007a863b433051a0da45302709946684;hp=0754d8a767af4fb6802905de5946a147e1965b4b;hb=de42b70bed81a6f47bbb8f614413ae9a04ec9940;hpb=3024b0b5a903a2bcb082b01e1787410dc9508a9d

diff --git a/tests/unbuffered001.phpt b/tests/unbuffered001.phpt
index 0754d8a..b0df231 100644
--- a/tests/unbuffered001.phpt
+++ b/tests/unbuffered001.phpt
@@ -16,7 +16,8 @@ var_dump($c->unbuffered);
 $c->execAsync("SELECT a from generate_series(1,10) a", function($res) {
 	switch ($res->status) {
 	case pq\Result::SINGLE_TUPLE:
-		printf("%s\n", $res->fetchCol());
+		$res->fetchCol("a", $val);
+		printf("%s\n", $val);
 		break;
 	case pq\Result::TUPLES_OK:
 		printf("-> fetching done\n");
@@ -26,22 +27,17 @@ $c->execAsync("SELECT a from generate_series(1,10) a", function($res) {
 		break;
 	}
 });
+
 do {
 	while ($c->busy) {
-		switch ($c->poll()) {
-			case pq\Connection::POLLING_READING:
-				$w=$e=array();
-				$r=array($c->socket);
-				stream:select($r,$w,$e,1);
-				break;
-			case pq\Connection::POLLING_WRITING:
-				$r=$e=array();
-				$w=array($c->socket);
-				stream_select($r,$w,$e,1);
-				break;
+		$r = array($c->socket);
+		$w = $e = null;
+		if (stream_select($r, $w, $e, null)) {
+			$c->poll();
 		}
 	}
 } while ($c->getResult());
+
 ?>
 DONE
 --EXPECTF--