55import ld_eventsource .config
66from typing import Callable
77
8-
98class SSEManager :
109 def __init__ (
1110 self ,
12- handlestate : Callable [[ld_eventsource .actions .Start ], None ],
13- handleerror : Callable [[ld_eventsource .actions .Fault ], None ],
14- handlemessage : Callable [[ld_eventsource .actions .Event ], None ],
11+ handle_state : Callable [[ld_eventsource .actions .Start ], None ],
12+ handle_error : Callable [[ld_eventsource .actions .Fault ], None ],
13+ handle_message : Callable [[ld_eventsource .actions .Event ], None ],
1514 ):
1615 self .client : ld_eventsource .SSEClient = None
1716 self .url = ""
18- self .handlestate = handlestate
19- self .handleerror = handleerror
20- self .handlemessage = handlemessage
17+ self .handle_state = handle_state
18+ self .handle_error = handle_error
19+ self .handle_message = handle_message
2120
2221 self .read_thread = threading .Thread (
2322 target = self .read_events ,
24- args = (self .handlestate , self .handleerror , self .handlemessage ),
23+ args = (self .handle_state , self .handle_error , self .handle_message ),
2524 )
2625
2726 def read_events (
2827 self ,
29- handlestate : Callable [[ld_eventsource .actions .Start ], None ],
30- handleerror : Callable [[ld_eventsource .actions .Fault ], None ],
31- handlemessage : Callable [[ld_eventsource .actions .Event ], None ],
28+ handle_state : Callable [[ld_eventsource .actions .Start ], None ],
29+ handle_error : Callable [[ld_eventsource .actions .Fault ], None ],
30+ handle_message : Callable [[ld_eventsource .actions .Event ], None ],
3231 ):
3332 self .client .start ()
3433 for event in self .client .all :
3534 if isinstance (event , ld_eventsource .actions .Start ):
36- handlestate (event )
35+ handle_state (event )
3736 elif isinstance (event , ld_eventsource .actions .Fault ):
38- handleerror (event )
37+ handle_error (event )
3938 elif isinstance (event , ld_eventsource .actions .Event ):
40- handlemessage (event )
39+ handle_message (event )
4140
4241 def update (self , config : dict ):
4342 if self .use_new_config (config ["sse" ]):
@@ -52,7 +51,7 @@ def update(self, config: dict):
5251 )
5352 self .read_thread = threading .Thread (
5453 target = self .read_events ,
55- args = (self .handlestate , self .handleerror , self .handlemessage ),
54+ args = (self .handle_state , self .handle_error , self .handle_message ),
5655 )
5756 self .read_thread .start ()
5857
0 commit comments