MongoDB ChangeStream watcher