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