INNER CODE UNIT · Python

__broadcast_notifications__

permitio/fastapi_websocket_pubsub · fastapi_websocket_pubsub/event_broadcaster.py:164

    async def __broadcast_notifications__(self, subscription: Subscription, data):
        """
        Share incoming internal notifications with the entire broadcast channel

        Args:
            subscription (Subscription): the subscription that got triggered
            data: the event data
        """
        logger.info(
            "Broadcasting incoming event: {}".format(
                {"topic": subscription.topic, "notifier_id": self._id}
            )
        )
        note = BroadcastNotification(
            notifier_id=self._id, topics=[subscription.topic], data=data
        )

        # Publish event to broadcast

View source record →