(self, image)
| 185 | atexit.register(self.shutdown) |
| 186 | |
| 187 | def put(self, image): |
| 188 | self.put_idx += 1 |
| 189 | self.task_queue.put((self.put_idx, image)) |
| 190 | |
| 191 | def get(self): |
| 192 | self.get_idx += 1 # the index needed for this request |
no outgoing calls
no test coverage detected