From 3d79ab65bfde8e55aefab997f84094c250bd4077 Mon Sep 17 00:00:00 2001 From: Rob Austein Date: Tue, 21 Apr 2009 02:39:10 +0000 Subject: Checkpoint svn path=/rpkid/rpki/async.py; revision=2351 --- rpkid/rpki/async.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'rpkid/rpki/async.py') 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() -- cgit v1.2.3