X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=ricsdl-package%2Fricsdl%2Fbackend%2Fdbbackend_abc.py;h=8805bdd58de5bc99cb8fd72535b51d19168da5fa;hb=77c5b120496bdcb798d0e02b719c177e8f48d4e9;hp=cdf031186a0a615ec559c36ba4a48d94ecc2ea55;hpb=a4392393ef8caf68217c2c5c59d13b183010422f;p=ric-plt%2Fsdlpy.git diff --git a/ricsdl-package/ricsdl/backend/dbbackend_abc.py b/ricsdl-package/ricsdl/backend/dbbackend_abc.py index cdf0311..8805bdd 100755 --- a/ricsdl-package/ricsdl/backend/dbbackend_abc.py +++ b/ricsdl-package/ricsdl/backend/dbbackend_abc.py @@ -161,12 +161,12 @@ class DbBackendAbc(ABC): pass @abstractmethod - def subscribe_channel(self, ns: str, cb: Callable[[str, str], None], + def subscribe_channel(self, ns: str, cb: Callable[[str, List[str]], None], channels: List[str]) -> None: """ This takes a callback function and one or many channels to be subscribed. When an event is received for the given channel, the given callback function - shall be called with channel and notifications as parameter. + shall be called with channel and notification(s) as parameter. """ pass @@ -184,10 +184,10 @@ class DbBackendAbc(ABC): pass @abstractmethod - def handle_events(self) -> Optional[Tuple[str, str]]: + def handle_events(self) -> Optional[Tuple[str, List[str]]]: """ handle_events is a non-blocking function that returns a tuple containing channel - name and message received from notification. + name and message(s) received from notification. """ pass