diff options
Diffstat (limited to 'amqp/promise.py')
-rw-r--r-- | amqp/promise.py | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/amqp/promise.py b/amqp/promise.py index 2e1d337..9540813 100644 --- a/amqp/promise.py +++ b/amqp/promise.py @@ -295,6 +295,12 @@ class promise(object): raise raise exc + @property + def listeners(self): + if self._lvpending: + return self._lvpending + return self._svpending + def throw(self, exc=None): if exc is None: return self.set_error_state() |