I guess it creates a new instance of changeStream on every change and at a point of time you’ll have all the changeStreams listening together in parallel. Not sure though. good question :))