| 105 | """ |
| 106 | |
| 107 | def __init__(self, handler: CommandHandler, key: str): |
| 108 | self.exception_queue = queue.SimpleQueue() |
| 109 | |
| 110 | start_signal = queue.SimpleQueue() |
| 111 | self.thread = threading.Thread(target=self.run, args=(start_signal, self.exception_queue, key, handler)) |
| 112 | self.thread.start() |
| 113 | |
| 114 | # Receive data from server once it starts |
| 115 | (event_loop, stop_signal, port) = start_signal.get(timeout=5) |
| 116 | self.event_loop = event_loop |
| 117 | self.stop_signal = stop_signal |
| 118 | self.port = port |
| 119 | logging.info("Server started") |
| 120 | |
| 121 | def run( |
| 122 | self, start_signal: queue.SimpleQueue, exception_queue: queue.SimpleQueue, key: str, handler: CommandHandler |