graphql - 嵌套在类型中的 Apollo 服务器订阅
问题描述
我正在尝试获取在 Apollo Server 2 中工作的订阅的解析器。订阅在它是顶级字段时工作(即直接在Subscription
根目录下schema
)。
但是,如果订阅包含在另一个type
中,我总是Subscription field must return Async Iterable. Received: undefined
在客户端的 websocket 连接上收到错误——服务器的解析器永远不会执行。
即这个模式有效:
type Subscription {
postAdded: Post
}
但是这个没有:
type Subscription {
post: PostSubscription
}
type PostSubscription {
postAdded: Post
}
我的第二种情况的解析器看起来像这样,但我尝试了一堆不同的变体,但没有成功:
Subscription: {
post: () => ({
PostSubscription: {}
})
},
PostSubscription: {
postAdded: {
subscribe: () => pubSub.asyncIterator(['postAdded'])
}
}
解决方案
错误消息表示您的帖子解析器
Subscription: {
post: () => ({
PostSubscription: {} // This needs to return AsyncIterator
})
},
如果我理解正确,你想订阅一个 postAdded、postDeleted、postUpdated,所有三个都在帖子下。我了解您想尝试在相同的模型下命名它们,这有助于更好地组织。但它有一些问题,我稍后会解释。
一句话建议: 最好把这3个字段直接放在根订阅字段下面。
并不是说你做不到,但如果你真的想要,假设你正在订阅
Subscription{
post{
postAdded: Post
postDeleted: Post
postUpdated(id:Int!): Post
}
}
那么三个嵌套字段都“共享”同一个频道。
然后你需要做几件事
- post 的订阅函数返回异步迭代器,不是 postAdd,而是 post 字段。
Subscription: {
post: {
subscription: () => pubSub.asyncIterator(['postChannel'])
}
}
- 然后在突变函数中,后突变(添加,更新,删除),您需要弄清楚要发送给客户端的内容。
像这样的东西
Mutation{
createPost: (_,args,context,info)=>{
const createdObject = // do create
pubsub.publish("postChannel", {
post:{
// do not do postUpdate, postDelete, because there's nothing updated, deleted
postAdded:createdObject
}
})
}
}
这将使您想要的工作正常,但这有几个问题。1. 任何时候发生任何更新/创建/删除,都会通知客户端。这可能会给客户提供不正确的信息。像这样如果客户订阅
subscription{
post{
postAdded
}
}
然后当其他人更新帖子时,客户端会得到这样的响应
response = {
subscription:{
postAdded:null
}
}
这可能可以忽略 postAdd 的 null。但是对于postUpdate来说肯定是个问题。想象一个用户订阅
subscribe{
post{
postUpdate(id:1)
}
}
然后有人添加了帖子,客户端总是会收到通知,因为这三个事件共享同一个频道。然后他会收到
response = {
subscription:{
postUpdated:null
}
}
然后,如果您使用的是 apollo 客户端,它将从缓存中删除 post:1,因为它会认为该 post 为空。
由于这些问题,强烈建议创建多个通道,最好每个模型三个通道。并创建三个根级别订阅而不是嵌套它们。
对于最低工作订阅,我会将您重定向到我为演示订阅而制作的 git-repo https://github.com/hansololai/apollo_subscription_boilerplate
推荐阅读
- python - 为什么此代码会出错:“缩进错误:未缩进与任何外部缩进都不匹配”
- angular - 我想在使用 switchMap 抛出错误时捕获错误
- php - 使用 PHP 后台任务获取 HTTP 1.1 错误 400
- url - 将 Yii2 GridView 列格式化为 URL
- ios - 选择按钮时如何触发键盘打开并启用听写
- android - 错误:来自 [androidx.core:core:1.0.0] 的属性 application@appComponentFactory value=(androidx.core.app.CoreComponentFactory)
- javascript - 使用javascript动态调整文本框的宽度和屏幕大小
- android - 为 BaseAdapter 类中的所有微调器设置相同的宽度
- c++ - Raspberry Buster 上 CLANG 中的代码或编译器错误
- drupal-8 - 无法安装闪电模块,因为它不存在