implemented collection.whenChanged and collection.updates event streams