):
"""
Generate tasks for all notification for an event.
:param subscribers: A list of subscribers who want to be notified for event.
):
"""
Generate tasks for all notification for an event.
:param subscribers: A list of subscribers who want to be notified for event.
- self.send_notification(session, notification, loop=loop),
- loop=loop,
+ self.send_notification(session, notification),
async def send_notification(
self,
session: aiohttp.ClientSession,
notification: dict,
async def send_notification(
self,
session: aiohttp.ClientSession,
notification: dict,
after maximum number of reties, then notification is dropped.
:param session: An aiohttp client session object to maintain http session.
:param notification: A dictionary containing all necessary data to make POST request.
after maximum number of reties, then notification is dropped.
:param session: An aiohttp client session object to maintain http session.
:param notification: A dictionary containing all necessary data to make POST request.
:param retry_count: An integer specifying the maximum number of reties for a notification.
:param timeout: A float representing client timeout of each HTTP request.
"""
:param retry_count: An integer specifying the maximum number of reties for a notification.
:param timeout: A float representing client timeout of each HTTP request.
"""