(self)
| 59 | self.do_request() |
| 60 | |
| 61 | def do_request(self): |
| 62 | if self.pending and self.reply_address and self.sender.credit: |
| 63 | request, future = self.pending.pop(0) |
| 64 | self.sent.append((request, future)) |
| 65 | req = Message(reply_to=self.reply_address, body=request) |
| 66 | self.sender.send(req) |
| 67 | |
| 68 | def request(self, body): |
| 69 | future = Future() |
no test coverage detected