We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 685f0ba commit 848c241Copy full SHA for 848c241
src/pg/mod.rs
@@ -775,7 +775,7 @@ impl AsyncPgConnection {
775
) -> impl futures_core::Stream<Item = QueryResult<diesel::pg::PgNotification>> + '_ {
776
match &mut self.notification_rx {
777
None => Either::Left(futures_util::stream::pending()),
778
- Some(rx) => Either::Right(futures_util::stream::unfold(rx, async |rx| {
+ Some(rx) => Either::Right(futures_util::stream::unfold(rx, |rx| async {
779
rx.recv().await.map(move |item| (item, rx))
780
})),
781
}
0 commit comments