33import ld_eventsource
44import ld_eventsource .actions
55import ld_eventsource .config
6+ from typing import Callable
67
78
89class SSEManager :
910 def __init__ (
10- self ,
11- handlestate : callable ( ld_eventsource .actions .Start ) ,
12- handleerror : callable ( ld_eventsource .actions .Fault ) ,
13- handlemessage : callable ( ld_eventsource .actions .Event ) ,
11+ 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 ] ,
1415 ):
1516 self .client : ld_eventsource .SSEClient = None
1617 self .url = ""
@@ -24,10 +25,10 @@ def __init__(
2425 )
2526
2627 def read_events (
27- self ,
28- handlestate : callable ( ld_eventsource .actions .Start ) ,
29- handleerror : callable ( ld_eventsource .actions .Fault ) ,
30- handlemessage : callable ( ld_eventsource .actions .Event ) ,
28+ 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 ] ,
3132 ):
3233 self .client .start ()
3334 for event in self .client .all :
0 commit comments