first rev

direct/src/showbase/BulletinBoardWatcher.py

@@ -0,0 +1,39 @@
+from direct.directnotify import DirectNotifyGlobal
+from direct.showbase.PythonUtil import Functor
+from direct.showbase import DirectObject
+
+class BulletinBoardWatcher(DirectObject.DirectObject):
+    """This class allows you to wait for N posts to be made to the bulletin
+    board, and give you a notification when all posts have been made. Values
+    of posts are not examined."""
+    notify = DirectNotifyGlobal.directNotify.newCategory('BulletinBoardWatcher')
+
+    def __init__(self, name, postNames, callback):
+        self.notify.debug('__init__: %s, %s, %s' % (name, postNames, callback))
+        self.name = name
+        self.postNames = postNames
+        self.callback = callback
+        self.waitingOn = {}
+        for name in postNames:
+            if not bboard.has(name):
+                eventName = bboard.getEventName(name)
+                self.acceptOnce(eventName, Functor(self.handlePost, eventName))
+                self.waitingOn[eventName] = None
+        self.checkDone()
+
+    def destroy(self):
+        self.ignoreAll()
+
+    def isDone(self):
+        return len(self.waitingOn) == 0
+
+    def checkDone(self):
+        if self.isDone():
+            self.notify.debug('%s: done' % self.name)
+            self.callback()
+
+    def handlePost(self, eventName):
+        self.notify.debug('%s: handlePost(%s)' % (self.name, eventName))
+        assert eventName in self.waitingOn
+        del self.waitingOn[eventName]
+        self.checkDone()