diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-07-17 10:17:10 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2016-07-17 10:17:10 -0700 |
| commit | 87648d74f49dafb6146bb61c40d8d2d44146ff8b (patch) | |
| tree | 6aa73d6711aa66eacca0a5d1b1f644c819f84bf6 /kafka/future.py | |
| parent | ade3160a4b954f5460f4a0aa34d4664d07a0e378 (diff) | |
| download | kafka-python-87648d74f49dafb6146bb61c40d8d2d44146ff8b.tar.gz | |
Simplify RecordMetadata; short circuit callbacks (#768)
Simplify RecordMetadata to unaltered namedtuple -- minor speed optimization
Minor optimization: inline check for no callbacks
Diffstat (limited to 'kafka/future.py')
| -rw-r--r-- | kafka/future.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/kafka/future.py b/kafka/future.py index a4b7deb..4a3af47 100644 --- a/kafka/future.py +++ b/kafka/future.py @@ -30,7 +30,8 @@ class Future(object): assert not self.is_done, 'Future is already complete' self.value = value self.is_done = True - self._call_backs('callback', self._callbacks, self.value) + if self._callbacks: + self._call_backs('callback', self._callbacks, self.value) return self def failure(self, e): |