(self, event)
| 52 | self.do_request() |
| 53 | |
| 54 | def on_message(self, event): |
| 55 | if self.sent: |
| 56 | request, future = self.sent.pop(0) |
| 57 | print("%s => %s" % (request, event.message.body)) |
| 58 | future.set_result(event.message.body) |
| 59 | self.do_request() |
| 60 | |
| 61 | def do_request(self): |
| 62 | if self.pending and self.reply_address and self.sender.credit: |
nothing calls this directly
no test coverage detected