Instead of this:

cursor = yield collection.aggregate(pipeline)

This:

cursor = collection.aggregate(pipeline)

(Substitute "yield from" or "await" for "yield" where appropriate.)

Implementation: aggregate will now return a "latent" cursor that does no I/O until the first "yield fetch_next", much like a regular query cursor.