__init__.py 文件源码

def broadcast(self, message, channel, sender):
        subscribers = self.get_subscribers(channel)
        for subscriber in subscribers:
            if subscriber != sender:
                try:
                    subscriber.write_message(message)
                except WebSocketClosedError:
                    self.remove_subscriber(channel, subscriber)