emit events when reading from mongo query stream