(self)
| 295 | self.mavlink_thread_out.start() |
| 296 | |
| 297 | def close(self): |
| 298 | # TODO this can block forever if parameters continue to be added |
| 299 | self._alive = False |
| 300 | while not self.out_queue.empty(): |
| 301 | time.sleep(0.1) |
| 302 | self.stop_threads() |
| 303 | self.master.close() |
| 304 | |
| 305 | def pipe(self, target): |
| 306 | target.target_system = self.target_system |
no test coverage detected