@@ -306,7 +306,6 @@ def __init__(
306
306
self ._pending_handlers : OrderedDict [Tuple [str , str ], ServiceStateChange ] = OrderedDict ()
307
307
self ._service_state_changed = Signal ()
308
308
self .query_scheduler = QueryScheduler (self .types , delay , _FIRST_QUERY_DELAY_RANDOM_INTERVAL )
309
- self .queue : Optional [queue .SimpleQueue ] = None
310
309
self .done = False
311
310
self ._first_request : bool = True
312
311
self ._next_send_timer : Optional [asyncio .TimerHandle ] = None
@@ -522,7 +521,7 @@ def __init__(
522
521
# Add the queue before the listener is installed in _setup
523
522
# to ensure that events run in the dedicated thread and do
524
523
# not block the event loop
525
- self .queue = queue .SimpleQueue ()
524
+ self .queue : queue . SimpleQueue = queue .SimpleQueue ()
526
525
self .daemon = True
527
526
self .start ()
528
527
zc .loop .call_soon_threadsafe (self ._async_start )
@@ -534,14 +533,12 @@ def __init__(
534
533
def cancel (self ) -> None :
535
534
"""Cancel the browser."""
536
535
assert self .zc .loop is not None
537
- assert self .queue is not None
538
536
self .queue .put (None )
539
537
self .zc .loop .call_soon_threadsafe (self ._async_cancel )
540
538
self .join ()
541
539
542
540
def run (self ) -> None :
543
541
"""Run the browser thread."""
544
- assert self .queue is not None
545
542
while True :
546
543
event = self .queue .get ()
547
544
if event is None :
@@ -555,6 +552,5 @@ def async_update_records_complete(self) -> None:
555
552
556
553
This method will be run in the event loop.
557
554
"""
558
- assert self .queue is not None
559
555
while self ._pending_handlers :
560
556
self .queue .put (self ._pending_handlers .popitem (False ))
0 commit comments