This is example code for wrapping the AsyncIterator in a graphql subscription resolver, so that you can execute cleanup code when a client unsubscribes.
Check out the blog post here!
To get working, simply clone the repo and run yarn and yarn dev.