diff --git a/postgres/src/generic_client.rs b/postgres/src/generic_client.rs index f2b1bf2e..2c633afd 100644 --- a/postgres/src/generic_client.rs +++ b/postgres/src/generic_client.rs @@ -108,7 +108,7 @@ pub trait GenericClient { common!(Self::Transaction<'_>, Self::Error); - fn block_for_notify(&mut self) -> Result, Self::Error>; + fn check_for_notify(&mut self) -> Result, Self::Error>; } impl GenericClient for Client { @@ -192,9 +192,9 @@ impl GenericClient for Client { self.transaction() } - fn block_for_notify(&mut self) -> Result, Error> { + fn check_for_notify(&mut self) -> Result, Self::Error> { let mut n = self.notifications(); - let mut n = n.blocking_iter(); + let mut n = n.iter(); n.next() } } @@ -296,7 +296,7 @@ impl GenericClient for Transaction<'_> { type Row = Row; transaction_common!(Self::Transaction<'_>); - fn block_for_notify(&mut self) -> Result, Self::Error> { + fn check_for_notify(&mut self) -> Result, Self::Error> { Ok(None) } }