Skip to content

Commit dfb61df

Browse files
committed
Don't fail on drop with a desynched stream
1 parent 6e37db3 commit dfb61df

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

src/lib.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -378,7 +378,7 @@ impl Drop for InnerPostgresConnection {
378378
fn drop(&mut self) {
379379
if !self.finished {
380380
match self.finish_inner() {
381-
Ok(()) => {}
381+
Ok(()) | Err(PgStreamDesynchronized) => {}
382382
Err(err) =>
383383
fail_unless_failing!("Error dropping connection: {}", err)
384384
}
@@ -874,7 +874,7 @@ impl<'conn> Drop for PostgresTransaction<'conn> {
874874
fn drop(&mut self) {
875875
if !self.finished {
876876
match self.finish_inner() {
877-
Ok(()) => {}
877+
Ok(()) | Err(PgStreamDesynchronized) => {}
878878
Err(err) =>
879879
fail_unless_failing!("Error dropping transaction: {}", err)
880880
}
@@ -1062,7 +1062,7 @@ impl<'conn> Drop for NormalPostgresStatement<'conn> {
10621062
fn drop(&mut self) {
10631063
if !self.finished.get() {
10641064
match self.finish_inner() {
1065-
Ok(()) => {}
1065+
Ok(()) | Err(PgStreamDesynchronized) => {}
10661066
Err(err) =>
10671067
fail_unless_failing!("Error dropping statement: {}", err)
10681068
}
@@ -1304,7 +1304,7 @@ impl<'stmt> Drop for PostgresResult<'stmt> {
13041304
fn drop(&mut self) {
13051305
if !self.finished {
13061306
match self.finish_inner() {
1307-
Ok(()) => {}
1307+
Ok(()) | Err(PgStreamDesynchronized) => {}
13081308
Err(err) =>
13091309
fail_unless_failing!("Error dropping result: {}", err)
13101310
}

0 commit comments

Comments
 (0)