INNER CODE UNIT · Python

trigger_events

permitio/fastapi_websocket_pubsub · fastapi_websocket_pubsub/event_notifier.py:166

    async def trigger_events(event_callbacks: List[Coroutine], *args):
        callbacks_with_params = []
        for callback in event_callbacks:
            callbacks_with_params.append(callback(*args))
        await asyncio.gather(*callbacks_with_params)

    async def trigger_callback(
        self,
        data,
        topic: Topic,
        subscriber_id: SubscriberId,
        subscription: Subscription,
    ):
        await subscription.callback(subscription, data)

    async def callback_subscribers(
        self,
        subscribers: Dict[SubscriberId, List[Subscription]],

View source record →