Currently there is a race and the aggregate / map reduce returns immediately with a MongoIterable which could be iterated before the aggregate / map reduce has completed.