From 4ad06c974fbd6f5c470feea26700073d5800b24d Mon Sep 17 00:00:00 2001
From: eitani <eitani@e2bd861d-eb25-0410-b326-f6ed22b6b98c>
Date: Wed, 23 Jan 2008 21:35:32 +0000
Subject: [PATCH] * registry.py (Registry.pumpQueuedEvents): Added this method
 for pumping queued events (bug #509412). Thanks Steve Lee!

git-svn-id: http://svn.gnome.org/svn/at-spi/trunk@981 e2bd861d-eb25-0410-b326-f6ed22b6b98c
---
 pyatspi/ChangeLog   |  5 +++++
 pyatspi/registry.py | 32 ++++++++++++++++++++++++++++++++
 2 files changed, 37 insertions(+)

diff --git a/pyatspi/ChangeLog b/pyatspi/ChangeLog
index d32e838..deaf5b1 100644
--- a/pyatspi/ChangeLog
+++ b/pyatspi/ChangeLog
@@ -1,3 +1,8 @@
+2008-01-23  Eitan Isaacson  <eitan@ascender.com>
+
+	* registry.py (Registry.pumpQueuedEvents): Added this method for
+	pumping queued events (bug #509412). Thanks Steve Lee!
+
 2009-01-12  Willie Walker  <william.walker@sun.com>
 
 	* accessible.py: fix for bug 503091 - getApplication doesn't
diff --git a/pyatspi/registry.py b/pyatspi/registry.py
index ef285e1..de37259 100644
--- a/pyatspi/registry.py
+++ b/pyatspi/registry.py
@@ -364,6 +364,7 @@ class Registry(object):
     except RuntimeError:
       # ignore errors when quitting (probably already quitting)
       pass
+    self.flushEvents()
     
   def getDesktopCount(self):
     '''
@@ -643,6 +644,37 @@ class Registry(object):
         # don't allow further processing if a client returns True
         break
 
+  def flushEvents(self):
+    '''
+    Flushes the event queue by destroying it and recreating it.
+    '''
+    self.queue = Queue.Queue()
+
+  def pumpQueuedEvents(self, num=-1):
+    '''
+    Provides asynch processing of events in the queue by executeing them with 
+    _dispatchEvent() (as is done immediately when synch processing). 
+    This method would normally be called from a main loop or idle function.
+
+    @param num: Number of events to pump. If number is negative it pumps
+    the entire queue. Default is -1.
+    @type num: integer
+    @return: True if queue is not empty after events were pumped.
+    @rtype: boolean
+    '''
+    if num < 0:
+      # Dequeue as many events as currently in the queue.
+      num = self.queue.qsize()
+    for i in xrange(num):
+      try:
+        # get next waiting event
+        event = self.queue.get_nowait()
+      except Queue.Empty:
+        break
+      self._dispatchEvent(event)
+
+    return not self.queue.empty()
+ 
   def _registerClients(self, client, name):
     '''
     Internal method that recursively associates a client with AT-SPI event 
-- 
2.7.4