@@ -105,7 +105,7 @@ def run() -> None:
105105 if isinstance (listener_ , weakref .ref ):
106106 listener = listener_ ()
107107 if listener is None :
108- listeners .remove (listener_ )
108+ listeners .discard (listener_ )
109109 continue
110110 else :
111111 listener = listener_
@@ -117,7 +117,7 @@ def run() -> None:
117117 if isinstance (event_handler_ , weakref .ref ):
118118 event_handler = event_handler_ ()
119119 if event_handler is None :
120- event_handlers [type (event )].remove (
120+ event_handlers [type (event )].discard (
121121 (event_handler_ , options ),
122122 )
123123 continue
@@ -182,7 +182,7 @@ def subscribe_event(
182182 event_handlers [cast (type [Event ], event_type )].add (
183183 (handler_ref , subscription_options ),
184184 )
185- return lambda : event_handlers [cast (type [Event ], event_type )].remove (
185+ return lambda : event_handlers [cast (type [Event ], event_type )].discard (
186186 (handler_ref , subscription_options ),
187187 )
188188
@@ -255,7 +255,7 @@ def check_and_call(state: State) -> None:
255255 if isinstance (subscriber_ , weakref .ref ):
256256 subscriber = subscriber_ ()
257257 if subscriber is None :
258- subscriptions .remove (subscriber_ )
258+ subscriptions .discard (subscriber_ )
259259 continue
260260 else :
261261 subscriber = subscriber_
@@ -291,7 +291,7 @@ def subscribe(
291291 callback (self .value )
292292
293293 def unsubscribe () -> None :
294- subscriptions .remove (callback_ref )
294+ subscriptions .discard (callback_ref )
295295
296296 return unsubscribe
297297
0 commit comments