cola/notification.py

   1 import os
   2 from PyQt4 import QtCore
   3
   4 from cola.compat import set
   5 from cola.decorators import memoize
   6
   7
   8 debug = os.environ.get('COLA_NOTIFIER_DEBUG', False)
   9
  10
  11 @memoize
  12 def notifier():
  13     return Notifier()
  14
  15
  16 class Notifier(object):
  17     """A pure-python re-implementation of QObject."""
  18     def __init__(self):
  19         self.channels = {}
  20
  21     def broadcast(self, signal, *args, **opts):
  22         if debug:
  23             print ('broadcast: %s(%s, %s)' % (name,
  24                                               args or '<empty>',
  25                                               kwargs or '<empty>'))
  26         self.emit(signal, *args, **opts)
  27
  28     def emit(self, signal, *args, **opts):
  29         subscribers = self.channels.get(signal, None)
  30         if subscribers:
  31             for fxn in subscribers:
  32                 fxn(*args, **opts)
  33
  34     def connect(self, signal, callback):
  35         subscribers = self.channels.setdefault(signal, set())
  36         subscribers.add(callback)