diff options
| author | Josh Morman <jmorman@gnuradio.org> | 2021-11-24 12:53:58 -0500 |
|---|---|---|
| committer | mormj <34754695+mormj@users.noreply.github.com> | 2021-11-24 14:41:53 -0500 |
| commit | 51ec89501552c35b2bd0721c0501302f224fe44d (patch) | |
| tree | 442036c424c286ece0976dcd3c36891cddefcd25 /gnuradio-runtime/python/gnuradio/gr/pubsub.py | |
| parent | e426b9ad20dbbf41326c103b31a7418a80362b06 (diff) | |
runtime: pep8 formatting
Signed-off-by: Josh Morman <jmorman@gnuradio.org>
Diffstat (limited to 'gnuradio-runtime/python/gnuradio/gr/pubsub.py')
| -rw-r--r-- | gnuradio-runtime/python/gnuradio/gr/pubsub.py | 31 |
1 files changed, 19 insertions, 12 deletions
diff --git a/gnuradio-runtime/python/gnuradio/gr/pubsub.py b/gnuradio-runtime/python/gnuradio/gr/pubsub.py index 11f53d5597..87e99785a6 100644 --- a/gnuradio-runtime/python/gnuradio/gr/pubsub.py +++ b/gnuradio-runtime/python/gnuradio/gr/pubsub.py @@ -17,9 +17,9 @@ This is a proof of concept implementation, will likely change significantly. class pubsub(dict): def __init__(self): - self._publishers = { } - self._subscribers = { } - self._proxies = { } + self._publishers = {} + self._subscribers = {} + self._proxies = {} def __missing__(self, key, value=None): dict.__setitem__(self, key, value) @@ -41,7 +41,8 @@ class pubsub(dict): sub(val) def __getitem__(self, key): - if key not in self: self.__missing__(key) + if key not in self: + self.__missing__(key) if self._proxies[key] is not None: (p, newkey) = self._proxies[key] return p[newkey] @@ -51,7 +52,8 @@ class pubsub(dict): return dict.__getitem__(self, key) def publish(self, key, publisher): - if key not in self: self.__missing__(key) + if key not in self: + self.__missing__(key) if self._proxies[key] is not None: (p, newkey) = self._proxies[key] p.publish(newkey, publisher) @@ -59,7 +61,8 @@ class pubsub(dict): self._publishers[key] = publisher def subscribe(self, key, subscriber): - if key not in self: self.__missing__(key) + if key not in self: + self.__missing__(key) if self._proxies[key] is not None: (p, newkey) = self._proxies[key] p.subscribe(newkey, subscriber) @@ -81,13 +84,16 @@ class pubsub(dict): self._subscribers[key].remove(subscriber) def proxy(self, key, p, newkey=None): - if key not in self: self.__missing__(key) - if newkey is None: newkey = key + if key not in self: + self.__missing__(key) + if newkey is None: + newkey = key self._proxies[key] = (p, newkey) def unproxy(self, key): self._proxies[key] = None + # Test code if __name__ == "__main__": import sys @@ -106,27 +112,28 @@ if __name__ == "__main__": class subber(object): def __init__(self, param): self._param = param + def printer(self, x): print(self._param, repr(x)) s = subber('param') o.subscribe('foo', s.printer) # The third is a lambda function - o.subscribe('foo', lambda x: sys.stdout.write('val='+repr(x)+'\n')) + o.subscribe('foo', lambda x: sys.stdout.write('val=' + repr(x) + '\n')) # Update key 'foo', will notify subscribers print("Updating 'foo' with three subscribers:") - o['foo'] = 'bar'; + o['foo'] = 'bar' # Remove first subscriber o.unsubscribe('foo', print_len) # Update now will only trigger second and third subscriber print("Updating 'foo' after removing a subscriber:") - o['foo'] = 'bar2'; + o['foo'] = 'bar2' # Publish a key as a function, in this case, a lambda function - o.publish('baz', lambda : 42) + o.publish('baz', lambda: 42) print("Published value of 'baz':", o['baz']) # Unpublish the key |