Mercurial > repos > shellac > guppy_basecaller
comparison env/lib/python3.7/site-packages/rdflib/events.py @ 0:26e78fe6e8c4 draft
"planemo upload commit c699937486c35866861690329de38ec1a5d9f783"
| author | shellac |
|---|---|
| date | Sat, 02 May 2020 07:14:21 -0400 |
| parents | |
| children |
comparison
equal
deleted
inserted
replaced
| -1:000000000000 | 0:26e78fe6e8c4 |
|---|---|
| 1 __doc__ = """ | |
| 2 Dirt Simple Events | |
| 3 | |
| 4 A Dispatcher (or a subclass of Dispatcher) stores event handlers that | |
| 5 are 'fired' simple event objects when interesting things happen. | |
| 6 | |
| 7 Create a dispatcher: | |
| 8 | |
| 9 >>> d = Dispatcher() | |
| 10 | |
| 11 Now create a handler for the event and subscribe it to the dispatcher | |
| 12 to handle Event events. A handler is a simple function or method that | |
| 13 accepts the event as an argument: | |
| 14 | |
| 15 >>> def handler1(event): print(repr(event)) | |
| 16 >>> d.subscribe(Event, handler1) | |
| 17 | |
| 18 Now dispatch a new event into the dispatcher, and see handler1 get | |
| 19 fired: | |
| 20 | |
| 21 >>> d.dispatch(Event(foo='bar', data='yours', used_by='the event handlers')) | |
| 22 <rdflib.events.Event ['data', 'foo', 'used_by']> | |
| 23 """ | |
| 24 | |
| 25 __all__ = ['Event', 'Dispatcher'] | |
| 26 | |
| 27 | |
| 28 class Event(object): | |
| 29 """ | |
| 30 An event is a container for attributes. The source of an event | |
| 31 creates this object, or a subclass, gives it any kind of data that | |
| 32 the events handlers need to handle the event, and then calls | |
| 33 notify(event). | |
| 34 | |
| 35 The target of an event registers a function to handle the event it | |
| 36 is interested with subscribe(). When a sources calls | |
| 37 notify(event), each subscriber to that event will be called in no | |
| 38 particular order. | |
| 39 """ | |
| 40 | |
| 41 def __init__(self, **kw): | |
| 42 self.__dict__.update(kw) | |
| 43 | |
| 44 def __repr__(self): | |
| 45 attrs = list(self.__dict__.keys()) | |
| 46 attrs.sort() | |
| 47 return '<rdflib.events.Event %s>' % ([a for a in attrs],) | |
| 48 | |
| 49 | |
| 50 class Dispatcher(object): | |
| 51 """ | |
| 52 An object that can dispatch events to a privately managed group of | |
| 53 subscribers. | |
| 54 """ | |
| 55 | |
| 56 _dispatch_map = None | |
| 57 | |
| 58 def set_map(self, amap): | |
| 59 self._dispatch_map = amap | |
| 60 | |
| 61 def get_map(self): | |
| 62 return self._dispatch_map | |
| 63 | |
| 64 def subscribe(self, event_type, handler): | |
| 65 """ Subscribe the given handler to an event_type. Handlers | |
| 66 are called in the order they are subscribed. | |
| 67 """ | |
| 68 if self._dispatch_map is None: | |
| 69 self.set_map({}) | |
| 70 lst = self._dispatch_map.get(event_type, None) | |
| 71 if lst is None: | |
| 72 lst = [handler] | |
| 73 else: | |
| 74 lst.append(handler) | |
| 75 self._dispatch_map[event_type] = lst | |
| 76 | |
| 77 def dispatch(self, event): | |
| 78 """ Dispatch the given event to the subscribed handlers for | |
| 79 the event's type""" | |
| 80 if self._dispatch_map is not None: | |
| 81 lst = self._dispatch_map.get(type(event), None) | |
| 82 if lst is None: | |
| 83 raise ValueError("unknown event type: %s" % type(event)) | |
| 84 for l in lst: | |
| 85 l(event) | |
| 86 | |
| 87 | |
| 88 def test(): | |
| 89 import doctest | |
| 90 doctest.testmod() | |
| 91 | |
| 92 if __name__ == '__main__': | |
| 93 test() |