diff options
author | Ask Solem <ask@celeryproject.org> | 2014-01-16 15:01:19 +0000 |
---|---|---|
committer | Ask Solem <ask@celeryproject.org> | 2014-01-16 15:01:19 +0000 |
commit | 97abf06e054398f22b7bf77aa6349d8a2ccd860b (patch) | |
tree | d4cabb26972ef44dbd836d3f7d43470654a50bd2 /amqp/utils.py | |
parent | bff6ddb0ea116e7c3b06f6cf2509c6411b3e4803 (diff) | |
parent | 07a312582d90b1303ff5d675613935392f6a6283 (diff) | |
download | py-amqp-readwrite.tar.gz |
Merge branch 'master' into readwritereadwrite
Conflicts:
amqp/transport.py
Diffstat (limited to 'amqp/utils.py')
-rw-r--r-- | amqp/utils.py | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/amqp/utils.py b/amqp/utils.py index 994030b..900d2aa 100644 --- a/amqp/utils.py +++ b/amqp/utils.py @@ -11,7 +11,8 @@ except ImportError: class promise(object): if not hasattr(sys, 'pypy_version_info'): __slots__ = tuple( - 'fun args kwargs value ready failed on_success on_error'.split() + 'fun args kwargs value ready failed ' + ' on_success on_error calls'.split() ) def __init__(self, fun, args=(), kwargs=(), @@ -24,6 +25,7 @@ class promise(object): self.on_success = on_success self.on_error = on_error self.value = None + self.calls = 0 def __repr__(self): return '<$: {0.fun.__name__}(*{0.args!r}, **{0.kwargs!r})'.format( @@ -43,6 +45,7 @@ class promise(object): self.on_success(self.value) finally: self.ready = True + self.calls += 1 def then(self, callback=None, on_error=None): self.on_success = callback |