(self)
| 289 | self.message_listeners.append(fn) |
| 290 | |
| 291 | def start(self): |
| 292 | if not self.mavlink_thread_in.is_alive(): |
| 293 | self.mavlink_thread_in.start() |
| 294 | if not self.mavlink_thread_out.is_alive(): |
| 295 | self.mavlink_thread_out.start() |
| 296 | |
| 297 | def close(self): |
| 298 | # TODO this can block forever if parameters continue to be added |
no outgoing calls