m6w6/atick

Asynchronous resource handling, optionally (ab)using ticks

atick

, _(*1)

Asynchronnous resource handling, optionally (ab)using ticks., _(*2)

Example with ticks:, _(*3)

declare(ticks=1);

$conn = new \pq\Connection;
$conn->execAsync("SELECT * FROM foo", function ($rs) {
    var_dump($rs);
});

$ticker = new \atick\Ticker;
$ticker->register();
$ticker->read($conn->socket, function($fd) use ($conn) {
    $conn->poll();
    if ($conn->busy) {
        return false;
    }
    $conn->getResult();
    return true;
});

while (count($ticker));

And an example without ticks:, _(*4)

$conn = new \pq\Connection;
$conn->execAsync("SELECT * FROM foo", function ($r) {
    var_dump($r);
});

$ticker = new \atick\Ticker;
$ticker->read($conn->socket, function($fd) use ($conn) {
    $conn->poll();
    if ($conn->busy) {
        return false;
    }
    $conn->getResult();
    return true;
});

while($ticker());