Skip to content

Commit 5f27c5c

Browse files
committed
type fix
1 parent aacb638 commit 5f27c5c

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

‎sqlx-core/src/postgres/listener.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -240,7 +240,7 @@ impl PgListener {
240240
pub async fn try_recv(&mut self) -> Result<Option<PgNotification>, Error> {
241241
// Flush the buffer first, if anything
242242
// This would only fill up if this listener is used as a connection
243-
if let Ok(Some(notification)) = self.buffer_rx.try_next() {
243+
if let Ok(notification) = self.buffer_rx.try_recv() {
244244
return Ok(Some(PgNotification(notification)));
245245
}
246246

0 commit comments

Comments
 (0)