Nice way to collect a cursor? about wither HOT 2 CLOSED

That is nicer, thank you!

from wither.

Hey there. A few things to keep in mind:

• The ModelCursor is a stream but is ALSO a TryStream — which is true for any stream yielding Results.
• As such, we have access to the TryStreamExt (as long as you bring it into scope), which means you have access to TryStreamExt::try_collect.

That said, all of the work is taken care of and we get the added bonus of easy error handling. So your above code could be refined down to:

use futures::prelude::*;
let cursor = Model::find(&db, filter, opts).await?;
let models: Vec<_> = cursor.try_collect().await?; // Gives you a `Vec<M>` just like your image above.

This will propagate an error if creating the cursor fails, but will also propagate an error if an error takes place while streaming over the cursor. The propagated error type in this case will always be a WitherError.

from wither.