aboutsummaryrefslogtreecommitdiff
path: root/rpkid/rpki/async.py
diff options
context:
space:
mode:
authorRob Austein <sra@hactrn.net>2009-04-21 02:39:10 +0000
committerRob Austein <sra@hactrn.net>2009-04-21 02:39:10 +0000
commit3d79ab65bfde8e55aefab997f84094c250bd4077 (patch)
tree26f0d7ba1211fc61f30125dc57a3830feba4024e /rpkid/rpki/async.py
parent024e74a42cbb21b431f0f7e1a70aaefbeefe0b0d (diff)
Checkpoint
svn path=/rpkid/rpki/async.py; revision=2351
Diffstat (limited to 'rpkid/rpki/async.py')
-rw-r--r--rpkid/rpki/async.py6
1 files changed, 5 insertions, 1 deletions
diff --git a/rpkid/rpki/async.py b/rpkid/rpki/async.py
index 4dc56d41..251dc253 100644
--- a/rpkid/rpki/async.py
+++ b/rpkid/rpki/async.py
@@ -25,10 +25,14 @@ class iterator(object):
self.handler_cb = handler_cb
self.done_cb = done_cb
self.iterator = iter(iterable)
+ self.next()
def __call__(self, *ignored):
+ self.next()
+
+ def next(self):
try:
- self.handler_cb(self.iterator.next())
+ self.handler_cb(self, self.iterator.next())
except StopIteration:
if self.done_cb is not None:
self.done_cb()