mirror of
https://github.com/vacp2p/de-mls.git
synced 2026-01-09 05:27:59 -05:00
fix lint error
This commit is contained in:
@@ -14,4 +14,3 @@ pub enum DeliveryServiceError {
|
||||
#[error("An unknown error occurred: {0}")]
|
||||
Other(anyhow::Error),
|
||||
}
|
||||
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
pub mod error;
|
||||
pub mod transport;
|
||||
pub mod topic_filter;
|
||||
pub mod transport;
|
||||
pub mod waku;
|
||||
|
||||
pub use error::DeliveryServiceError;
|
||||
|
||||
@@ -43,10 +43,7 @@ impl TopicFilter {
|
||||
|
||||
/// Remove all subtopics for a group.
|
||||
pub async fn remove_many(&self, group_name: &str) {
|
||||
self.list
|
||||
.write()
|
||||
.await
|
||||
.retain(|x| x.group_id != group_name);
|
||||
self.list.write().await.retain(|x| x.group_id != group_name);
|
||||
}
|
||||
|
||||
/// Membership test (first-stage filter).
|
||||
|
||||
@@ -4,8 +4,7 @@ use tracing::{debug, error, info};
|
||||
|
||||
use ds::{
|
||||
transport::{InboundPacket, OutboundPacket},
|
||||
APP_MSG_SUBTOPIC,
|
||||
WELCOME_SUBTOPIC,
|
||||
APP_MSG_SUBTOPIC, WELCOME_SUBTOPIC,
|
||||
};
|
||||
|
||||
use crate::{
|
||||
|
||||
@@ -360,7 +360,8 @@ async fn process_and_handle_trigger_event_message(
|
||||
msgs_to_send.extend(wmts);
|
||||
}
|
||||
|
||||
let waku_msgs_to_send: Vec<InboundPacket> = msgs_to_send.into_iter().map(outbound_to_inbound).collect();
|
||||
let waku_msgs_to_send: Vec<InboundPacket> =
|
||||
msgs_to_send.into_iter().map(outbound_to_inbound).collect();
|
||||
|
||||
let user_state = user
|
||||
.get_group_state(GROUP_NAME)
|
||||
|
||||
Reference in New Issue
Block a user