(self, message_hash)
| 79 | self.connected = Future() |
| 80 | |
| 81 | def future(self, message_hash): |
| 82 | if message_hash not in self.futures or self.futures[message_hash].cancelled(): |
| 83 | self.futures[message_hash] = Future() |
| 84 | future = self.futures[message_hash] |
| 85 | if message_hash in self.rejections: |
| 86 | future.reject(self.rejections[message_hash]) |
| 87 | del self.rejections[message_hash] |
| 88 | return future |
| 89 | |
| 90 | def reusable_future(self, message_hash): |
| 91 | return self.future(message_hash) # only used in go |
no test coverage detected