如何基于某些事件通过石墨烯订阅（websockets）发送响应

Question

下面的基本示例有效。但是，如果我想向订阅者（或所有订阅者（广播））发送我通过突变或添加到数据库后收到的消息（例如来自另一个客户端）怎么办？所以在一些事件之后？也许您可以建议我检查一些示例或链接？我正在使用 fastapi + 石墨烯 + websockets

class Subscription(g.ObjectType):

    count = g.Int()
​
    async def subscribe_count(self, info, target=20):
        for i in range(target):
            yield i
            await asyncio.sleep(0.5)
​
​
schema = g.Schema(query=Query, mutation=Mutation, subscription=Subscription)

试图找到一些例子或类似的问题，但没有找到任何关于在石墨烯中深度使用订阅的信息。将不胜感激任何帮助