diff --git a/payjoin-directory/src/db.rs b/payjoin-directory/src/db.rs index 679a0f40..7aabefdb 100644 --- a/payjoin-directory/src/db.rs +++ b/payjoin-directory/src/db.rs @@ -38,8 +38,8 @@ impl DbPool { async fn push(&self, pubkey_id: &str, channel_type: &str, data: Vec) -> RedisResult<()> { let mut conn = self.client.get_async_connection().await?; let key = channel_name(pubkey_id, channel_type); - conn.set(&key, data.clone()).await?; - conn.publish(&key, "updated").await?; + let () = conn.set(&key, data.clone()).await?; + let () = conn.publish(&key, "updated").await?; Ok(()) } @@ -75,8 +75,8 @@ impl DbPool { loop { match message_stream.next().await { Some(msg) => { - msg.get_payload()?; // Notification received - // Try fetching the data again + let () = msg.get_payload()?; // Notification received + // Try fetching the data again if let Some(data) = conn.get::<_, Option>>(&key).await? { if !data.is_empty() { break data; // Exit the block, returning the data