订阅
订阅
订阅只是另一种GraphQL操作类型，如Query和Mutation。它允许在双向传输层上创建实时订阅，主要通过websockets。在此处阅读有关订阅的更多信息。以下是commentAdded订阅示例，直接从官方Apollo文档中复制并粘贴：
Subscription: {
commentAdded: {
subscribe: () => pubSub.asyncIterator('commentAdded')
}
}
注意这pubsub是一个PubSub类的实例。
为了在Nest中创建一个等价的订阅，我们将使用@Subscription()装饰器。让我们AuthorResolver在解析器部分扩展我们的用法。
const pubSub = new PubSub(
@Resolver('Author')
export class AuthorResolver {
constructor(
private readonly authorsService: AuthorsService,
private readonly postsService: PostsService,
) {}
@Query('author')
async getAuthor(@Args('id') id: number) {
return await this.authorsService.findOneById(id
}
@ResolveProperty('posts')
async getPosts(@Parent() author) {
const { id } = author;
return await this.postsService.findAll{ authorId: id }
}
@Subscription()
commentAdded() {
return {
subscribe: () => pubSub.asyncIterator('commentAdded'),
};
}
}
我们PubSub在这里使用了一个本地实例。相反，我们应该定义PubSub为提供者，通过构造函数（使用@Inject()装饰器）注入它，并在整个应用程序中重用它。
模
为了启用订阅，我们必须将installSubscriptionHandlers属性设置为true。
GraphQLModule.forRoot{
typePaths: ['./**/*.graphql'],
installSubscriptionHandlers: true,
})
要自定义订阅服务器（例如，更改端口），您可以使用subscriptions属性。
类型定义
最后一步是更新类型定义文件。
type Author {
id: Int!
firstName: String
lastName: String
posts: [Post]
}
type Post {
id: Int!
title: String
votes: Int
}
type Query {
author(id: Int!): Author
}
type Comment {
id: String
content: String
}
type Subscription {
commentAdded(repoFullName: String!): Comment
}
做得好。我们创建了一个commentAdded(repoFullName: String!): Comment订阅。
