chk
/
AppFlowy-Cloud
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chore: fix clippy warnings

This commit is contained in:
Bartosz Sypytkowski 2024-10-23 11:39:51 +02:00
parent 5d0d8cf4d1
commit f123cc136f
3 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
libs/collab-rt-protocol/src/message.rs
View File

@ -43,7 +43,7 @@ impl Encode for Message {
}, },
Message::Awareness(update) => { Message::Awareness(update) => {
encoder.write_var(MSG_AWARENESS); encoder.write_var(MSG_AWARENESS);
encoder.write_buf(&update) encoder.write_buf(update)
}, },
Message::Custom(msg) => { Message::Custom(msg) => {
encoder.write_var(MSG_CUSTOM); encoder.write_var(MSG_CUSTOM);

6
libs/collab-stream/src/model.rs
View File

@ -427,8 +427,7 @@ impl FromRedisValue for CollabStreamUpdateBatch {
None => CollabOrigin::Empty, None => CollabOrigin::Empty,
Some(sender) => { Some(sender) => {
let raw_origin = String::from_redis_value(sender)?; let raw_origin = String::from_redis_value(sender)?;
let collab_origin = collab_origin_from_str(&raw_origin)?; collab_origin_from_str(&raw_origin)?
collab_origin
}, },
}; };
let state_vector = match fields.get("sv") { let state_vector = match fields.get("sv") {
@ -495,8 +494,7 @@ impl FromRedisValue for AwarenessStreamUpdateBatch {
None => CollabOrigin::Empty, None => CollabOrigin::Empty,
Some(sender) => { Some(sender) => {
let raw_origin = String::from_redis_value(sender)?; let raw_origin = String::from_redis_value(sender)?;
let collab_origin = collab_origin_from_str(&raw_origin)?; collab_origin_from_str(&raw_origin)?
collab_origin
}, },
}; };
let data_raw = fields let data_raw = fields

4
tests/collab/util.rs
View File

@ -136,9 +136,9 @@ impl TestScenario {
pub async fn execute(&self, collab: CollabRef) -> String { pub async fn execute(&self, collab: CollabRef) -> String {
let len = self.txns.len(); let len = self.txns.len();
let start = Instant::now(); let start = Instant::now();
for (i, t) in self.txns.iter().take(50_000).enumerate() { for (i, t) in self.txns.iter().enumerate() {
if i % 10_000 == 0 { if i % 10_000 == 0 {
tracing::trace!("step #{}/{} - {:?}", i + 1, len, start.elapsed()); tracing::info!("step #{}/{} - {:?}", i + 1, len, start.elapsed());
} }
let mut lock = collab.write().await; let mut lock = collab.write().await;
let collab = lock.borrow_mut(); let collab = lock.borrow_mut();