check the state of the queue before diving in to process it

darcs-hash:20080830095709-84dde-a64262c1b32e506cb2c43f8b4fb55ab88effc22f.gz

1 files changed, 8 insertions, 0 deletions

diff --git a/extlib/XMPPHP/XMLStream.php b/extlib/XMPPHP/XMLStream.php
index 4de23ef7f..62aa4de89 100644
--- a/extlib/XMPPHP/XMLStream.php
+++ b/extlib/XMPPHP/XMLStream.php
@@ -616,4 +616,12 @@ class XMPPHP_XMLStream {
 		xml_set_element_handler($this->parser, 'startXML', 'endXML');
 		xml_set_character_data_handler($this->parser, 'charXML');
 	}
+
+	public function readyToProcess() {
+		$read = array($this->socket);
+		$write = null;
+		$except = null;
+		$updated = @stream_select($read, $write, $except, 0);
+		return $updated !== false;
+	}
 }