Skip to content

Commit

Permalink
Fixes clippy warnings found when unstable feature is on
Browse files Browse the repository at this point in the history
Signed-off-by: Dhanuka Warusadura <dhanuka@gnome.org>
  • Loading branch information
warusadura authored and bilelmoussaoui committed Feb 9, 2024
1 parent 83d4480 commit a0d4dc7
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion client/src/dbus/api/properties.rs
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ use serde::{
ser::{Serialize, SerializeMap},
Deserialize,
};
use zbus::zvariant::{self, OwnedValue, Type, Value};
use zbus::zvariant::{self, Type, Value};

const ITEM_PROPERTY_LABEL: &str = "org.freedesktop.Secret.Item.Label";
const ITEM_PROPERTY_ATTRIBUTES: &str = "org.freedesktop.Secret.Item.Attributes";
Expand Down
6 changes: 3 additions & 3 deletions client/src/dbus/api/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ impl<'a> Service<'a> {
pub async fn receive_collection_created(
&self,
) -> Result<impl Stream<Item = Collection<'_>>, Error> {
let mut stream = self.inner().receive_signal("CollectionCreated").await?;
let stream = self.inner().receive_signal("CollectionCreated").await?;
let conn = self.inner().connection();
Ok(stream.filter_map(move |message| async move {
let path = message.body::<OwnedObjectPath>().ok()?;
Expand All @@ -49,7 +49,7 @@ impl<'a> Service<'a> {
pub async fn receive_collection_deleted(
&self,
) -> Result<impl Stream<Item = Collection<'_>>, Error> {
let mut stream = self.inner().receive_signal("CollectionDeleted").await?;
let stream = self.inner().receive_signal("CollectionDeleted").await?;
let conn = self.inner().connection();
Ok(stream.filter_map(move |message| async move {
let path = message.body::<OwnedObjectPath>().ok()?;
Expand All @@ -61,7 +61,7 @@ impl<'a> Service<'a> {
pub async fn receive_collection_changed(
&self,
) -> Result<impl Stream<Item = Collection<'_>>, Error> {
let mut stream = self.inner().receive_signal("CollectionChanged").await?;
let stream = self.inner().receive_signal("CollectionChanged").await?;
let conn = self.inner().connection();
Ok(stream.filter_map(move |message| async move {
let path = message.body::<OwnedObjectPath>().ok()?;
Expand Down

0 comments on commit a0d4dc7

Please sign in to comment.