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
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