File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1010import threading
1111from abc import ABCMeta , abstractmethod
1212from collections import defaultdict
13+ from typing import Dict , Any
1314
1415logger = logging .getLogger (__name__ )
1516# logger.setLevel(logging.DEBUG)
1617
1718
1819class EventFactory (metaclass = ABCMeta ):
19- def __init__ (self ):
20+ def __init__ (self ) -> None :
2021 self .new_event = threading .Event ()
2122 self ._reset_data ()
2223
2324 @abstractmethod
24- def _reset_data (self ):
25- raise NotImplementedError
25+ def _reset_data (self ) -> None :
26+ self . event_data : Dict [ str , Any ] = {}
2627
27- def next_event (self ):
28+ def next_event (self ) -> dict :
2829 """Returns an event and prepares the internal state so that it can start to build a new event"""
2930 self .new_event .clear ()
3031 data = self .event_data
3132 # self.logger.debug(f"Event: {data}")
3233 self ._reset_data ()
3334 return data
3435
35- def has_new_event (self ):
36+ def has_new_event (self ) -> bool :
3637 return self .new_event .is_set ()
3738
3839
You can’t perform that action at this time.
0 commit comments