NestJS，RethinkDB和Graphql订阅：PubSub不发布或阅读吗？

问题描述

我正在尝试获取graphql订阅以与nestjs和rethinkdb一起使用。基本上，订阅将更改提要从Rethinkdb发布到客户端。问题是，PubSub似乎没有发生。

这是负责发布Rethink的新事件的部分：

this.rethinkService.listen("connections",{routerId},async(err: Error,cursor: rethink.Cursor) => {
            const pub = new PubSub()
            cursor.each(async (err: Error,elem) => {
                if (err) return
                if (elem.new_val !== null) {
                    pub.publish(`router${routerId}-connections`,new ConnectionDto(elem.new_val))
                }
            })
        })

这是负责GraphQL订阅的部分：

    @Subscription(returns => ConnectionDto,{
        filter: (payload,variables) => {
            return payload.newConnection.routerId === variables.routerId
        }
    })
    async connectionAdded(@Args('routerId',{type: () => String}) routerId: string) {
        const pub = new PubSub()
        this.connectionService.listenToConnections(routerId)
        pub.subscribe(`newConnection`,(ev) => {
            console.log(ev)
        })
        return pub.asyncIterator(`newConnection`)
    }

嵌套的记录器未显示任何错误。

你能帮我吗？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）