Code Review
/
ric-plt
/
sdlpy.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
RIC:1060: Change in PTL
[ric-plt/sdlpy.git]
/
ricsdl-package
/
ricsdl
/
backend
/
dbbackend_abc.py
diff --git
a/ricsdl-package/ricsdl/backend/dbbackend_abc.py
b/ricsdl-package/ricsdl/backend/dbbackend_abc.py
index
49944b5
..
8805bdd
100755
(executable)
--- a/
ricsdl-package/ricsdl/backend/dbbackend_abc.py
+++ b/
ricsdl-package/ricsdl/backend/dbbackend_abc.py
@@
-161,13
+161,12
@@
class DbBackendAbc(ABC):
pass
@abstractmethod
pass
@abstractmethod
- def subscribe_channel(self, ns: str,
- cb: Union[Callable[[str, str], None], Callable[[str, List[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
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 notification
s
as parameter.
+ shall be called with channel and notification
(s)
as parameter.
"""
pass
"""
pass
@@
-185,7
+184,7
@@
class DbBackendAbc(ABC):
pass
@abstractmethod
pass
@abstractmethod
- def handle_events(self) -> Optional[
Union[Tuple[str, str], Tuple[str, List[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(s) received from notification.
"""
handle_events is a non-blocking function that returns a tuple containing channel
name and message(s) received from notification.