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

chore: fix early return from redis collab update stream reader

This commit is contained in:
Bartosz Sypytkowski 2024-10-17 12:58:20 +02:00
parent 15f438ea05
commit f40f4b1583
2 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
libs/collab-stream/src/client.rs
View File

@ -116,7 +116,7 @@ impl CollabRedisStream {
Some(id) => Some(MessageId::try_from(id)?), Some(id) => Some(MessageId::try_from(id)?),
} }
}; };
while Some(since) < until { while until.is_none() || since < until.unwrap() {
let last_id = since.to_string(); let last_id = since.to_string();
let batch: CollabStreamUpdateBatch = conn let batch: CollabStreamUpdateBatch = conn
.xread_options(&[&stream_key], &[&last_id], &read_options) .xread_options(&[&stream_key], &[&last_id], &read_options)

1
services/appflowy-collaborate/src/group/group_init.rs
View File

@ -523,7 +523,6 @@ impl CollabGroup {
message_origin: &CollabOrigin, message_origin: &CollabOrigin,
msg_id: MsgId, msg_id: MsgId,
) -> Result<Option<CollabAck>, RealtimeError> { ) -> Result<Option<CollabAck>, RealtimeError> {
tracing::trace!("handling collab message: {}", msg_id);
let mut decoder = DecoderV1::from(payload); let mut decoder = DecoderV1::from(payload);
let reader = MessageReader::new(&mut decoder); let reader = MessageReader::new(&mut decoder);
let mut ack_response = None; let mut ack_response = None;