equal
deleted
inserted
replaced
36 self.d.addErrback(partial(self.job.setError,self)) |
36 self.d.addErrback(partial(self.job.setError,self)) |
37 taskPool.run(self._run) |
37 taskPool.run(self._run) |
38 return self.d |
38 return self.d |
39 |
39 |
40 def _run(self): |
40 def _run(self): |
41 os= (i for i in self.job.offers) |
41 os= iter(self.job.offers) |
42 def n(): |
42 def n(): |
43 try: |
43 try: |
44 offer = os.next() |
44 offer = os.next() |
45 d = maybeDeferred(offers[offer],self.recipient,self.job.message) |
45 d = maybeDeferred(offers[offer],self.recipient,self.job.message) |
46 d.addCallback(self.d.callback) |
46 d.addCallback(self.d.callback) |