void pq\Connection::resetAsync()

Asynchronously reset a possibly broken connection to a working state.

Params:

None.

Throws:

Example:


<?php

$c
->resetAsync();

// wait until the stream becomes writable
$w = array($c->socket);
$r $e null;

if (
stream_select($r$w$enull)) {

  
// loop until the connection is established
  
while (true) {
  
    switch (
$c->poll()) {
    
    case 
pq\Connection::POLLING_READING:
      
// we should wait for the stream to be read-ready
      
$r = array($c->socket);
      
stream_select($r$w$eNULL);
      break;

    case 
pq\Connection::POLLING_WRITING:
      
// we should wait for the stream to be write-ready
      
$w = array($c->socket);
      
$r $e null;
      
stream_select($r$w$enull);
      break;

    case 
pq\Connection::POLLING_FAILED:
      
printf("Connection failed: %s\n"$c->errorMessage);
      break 
2;

    case 
pq\Connection::POLLING_OK:
      
printf("Connection completed\n");
      break 
2;
    }
}

?>