如何解决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 举报,一经查实,本站将立刻删除。