diff --git a/rhio/src/node/actor.rs b/rhio/src/node/actor.rs index f11db3a5..0a520918 100644 --- a/rhio/src/node/actor.rs +++ b/rhio/src/node/actor.rs @@ -375,6 +375,7 @@ fn is_subject_matching(subscriptions: &Vec, incoming: &ScopedSubje } /// Returns true if incoming blob announcement is of interested to our local node. +#[allow(unused_variables)] fn is_bucket_matching(subscriptions: &Vec, incoming: &ScopedBucket) -> bool { // @TODO false diff --git a/rhio/src/topic.rs b/rhio/src/topic.rs index 3cff5ec0..71d75c19 100644 --- a/rhio/src/topic.rs +++ b/rhio/src/topic.rs @@ -156,8 +156,8 @@ mod tests { bucket: ScopedBucket::new("airplanes", public_key_1), } .into(); - assert_eq!(subscription_0.id(), subscription_1.id()); - assert_ne!(subscription_1.id(), subscription_2.id()); + assert_ne!(subscription_0.id(), subscription_1.id()); + assert_eq!(subscription_1.id(), subscription_2.id()); // NATS subjects use public key as gossip topic id. let subscription_3: Query = Subscription::Subject {