@@ -329,7 +329,7 @@ def _async_start(self) -> None:
|
329 | 329 | self.query_scheduler.start(current_time_millis()) |
330 | 330 | self.zc.async_add_listener(self, [DNSQuestion(type_, _TYPE_PTR, _CLASS_IN) for type_ in self.types]) |
331 | 331 | # Only start queries after the listener is installed |
332 | | -asyncio.ensure_future(self._async_start_query_sender()) |
| 332 | +self._query_sender_task = asyncio.ensure_future(self._async_start_query_sender()) |
333 | 333 | |
334 | 334 | @property |
335 | 335 | def service_state_changed(self) -> SignalRegistrationInterface: |
@@ -436,6 +436,7 @@ def _async_cancel(self) -> None:
|
436 | 436 | self.done = True |
437 | 437 | self._cancel_send_timer() |
438 | 438 | self.zc.async_remove_listener(self) |
| 439 | +self._query_sender_task.cancel() |
439 | 440 | |
440 | 441 | def _generate_ready_queries(self, first_request: bool, now: float) -> List[DNSOutgoing]: |
441 | 442 | """Generate the service browser query for any type that is due.""" |
|