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.

I created a walkthrough video to show you the benefits of this approach, please take a look:

Did you like the video or would you have preferred a normal blog post? Let me know in the comments!