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, $e, null)) {

  // 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, $e, NULL);
	  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, $e, null);
	  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;
	}
}

?>