Implementing GraphQL Subscriptions with RxJS
I recently had to bootstrap a project with a GraphQL frontend and backend using Apollo. We wanted to show realtime updates of metrics we collect from an endpoint. For this, we wanted to use GraphQL Subscriptions, specifically graphql-subscriptions, but I noticed they use AsyncIterables as an abstraction for a stream of data. I used RxJS for the same purpose in the past and I like the abstractions it provides over asynchronicity and how it plays together with Typescript.