В Apollo Server, похоже, у вас есть AsyncIterator для распознавателей подписки:
const rootResolver = {
Query: () => { ... },
Mutation: () => { ... },
Subscription: {
commentAdded: {
subscribe: () => pubsub.asyncIterator('commentAdded')
}
},
};
Источник
Мне интересно, есть ли способвместо этого использовать RXJS Observable или каким-то образом преобразовать его в AsyncIterator?