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(Sqlite): stop sending rows after first error (#3700)

Browse Source
This commit is contained in:
joeydewaal 2025-01-24 23:41:29 +01:00 committed by GitHub
parent ad1d7a8aa5
commit f4c7498523
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
sqlx-sqlite/src/connection/worker.rs
View File

@ -151,7 +151,8 @@ impl ConnectionWorker {
match limit {
None => {
for res in iter {
if tx.send(res).is_err() {
let has_error = res.is_err();
if tx.send(res).is_err() || has_error {
break;
}
}
@ -171,7 +172,8 @@ impl ConnectionWorker {
}
}
}
if tx.send(res).is_err() {
let has_error = res.is_err();
if tx.send(res).is_err() || has_error {
break;
}
}