fix: block -> check

This commit is contained in:
2023-07-23 23:05:31 -05:00
parent 039be77d99
commit 620add44de

View File

@@ -108,7 +108,7 @@ pub trait GenericClient {
common!(Self::Transaction<'_>, Self::Error);
fn block_for_notify(&mut self) -> Result<Option<Notification>, Self::Error>;
fn check_for_notify(&mut self) -> Result<Option<Notification>, Self::Error>;
}
impl GenericClient for Client {
@@ -192,9 +192,9 @@ impl GenericClient for Client {
self.transaction()
}
fn block_for_notify(&mut self) -> Result<Option<Notification>, Error> {
fn check_for_notify(&mut self) -> Result<Option<Notification>, 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<Option<Notification>, Self::Error> {
fn check_for_notify(&mut self) -> Result<Option<Notification>, Self::Error> {
Ok(None)
}
}