itsscb/sqlx
1
0
Fork 0
mirror of https://github.com/launchbadge/sqlx.git synced 2025-12-29 21:00:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix bounds for F on query::Map

Browse Source 
Query::map was not usable before.
This commit is contained in:
Jonas Platte 2020-09-30 18:24:38 +02:00 committed by Ryan Leckey
parent 4ad4a42edd
commit 3b9c98d979
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
sqlx-core/src/query.rs
View File

@ -251,7 +251,7 @@ where
impl<'q, DB, F, O, A> Map<'q, DB, F, A>
where
DB: Database,
F: Send + Sync + Fn(DB::Row) -> Result<O, Error>,
F: TryMapRow<DB, Output = O>,
O: Send + Unpin,
A: 'q + Send + IntoArguments<'q, DB>,
{
@ -277,7 +277,7 @@ where
/// Execute multiple queries and return the generated results as a stream
/// from each query, in a stream.
pub fn fetch_many<'e, 'c: 'e, E>(
self,
mut self,
executor: E,
) -> BoxStream<'e, Result<Either<DB::Done, O>, Error>>
where
@ -294,7 +294,7 @@ where
r#yield!(match v {
Either::Left(v) => Either::Left(v),
Either::Right(row) => {
Either::Right((self.mapper)(row)?)
Either::Right(self.mapper.try_map_row(row)?)
}
});
}
@ -333,7 +333,7 @@ where
}
/// Execute the query and returns at most one row.
pub async fn fetch_optional<'e, 'c: 'e, E>(self, executor: E) -> Result<Option<O>, Error>
pub async fn fetch_optional<'e, 'c: 'e, E>(mut self, executor: E) -> Result<Option<O>, Error>
where
'q: 'e,
E: 'e + Executor<'c, Database = DB>,
@ -344,7 +344,7 @@ where
let row = executor.fetch_optional(self.inner).await?;
if let Some(row) = row {
(self.mapper)(row).map(Some)
self.mapper.try_map_row(row).map(Some)
} else {
Ok(None)
}