Currently the way to stop iterating an async cursor is to return false from the Block.

A better way might be to instead call cancel() on the Future returned from the forEach method() in the higher level API. This models more closely the way a Subscription works in RxJava.