chore: clippy

Author: appflowy

libs/appflowy-proto/src/client_message.rs

@@ -1,6 +1,7 @@
 use crate::pb;
 use crate::pb::collab_message::Data;
 use crate::pb::message::Payload;
+#[rustfmt::skip]
 use crate::pb::{message, SyncRequest};
 use crate::shared::{Error, ObjectId, Rid, UpdateFlags};
 use collab::preclude::sync::AwarenessUpdate;

libs/appflowy-proto/src/server_message.rs

@@ -2,7 +2,8 @@ use crate::pb;
 use crate::pb::collab_message::Data;
 use crate::pb::message::Payload;
 use crate::pb::notification::{PermissionChanged, UserProfileChange};
-use crate::pb::{message, SyncRequest};
+#[rustfmt::skip]
+use crate::pb::{SyncRequest, message};
 use crate::shared::{Error, ObjectId, Rid, UpdateFlags};
 use bytes::Bytes;
 use collab::preclude::sync::AwarenessUpdate;

libs/collab-stream/src/stream_router.rs

@@ -202,6 +202,7 @@ struct Worker {
 }
 
 impl Worker {
+  #[allow(clippy::too_many_arguments)]
   fn new(
     worker_id: usize,
     conn: Connection,
@@ -230,6 +231,7 @@ impl Worker {
     Self { _handle: handle }
   }
 
+  #[allow(clippy::too_many_arguments)]
   fn process_streams(
     mut conn: Connection,
     tx: Sender<StreamHandle>,