diff --git a/postgres/src/lib.rs b/postgres/src/lib.rs index 1c2b3d77..8fa3ffe0 100644 --- a/postgres/src/lib.rs +++ b/postgres/src/lib.rs @@ -329,7 +329,7 @@ impl InnerConnection { loop { match try_desync!(self, self.stream.read_message()) { backend::Message::NoticeResponse(body) => { - if let Ok(err) = Err(err(&mut body.fields())) { + if let Ok(err) = DbError::new(&mut body.fields()){ self.notice_handler.handle_notice(err); } }